代码实现子线程与子线程的子线程的同步

下面是一个使用多级队列和条件变量实现子线程与子线程的子线程同步的示例代码：

#include <iostream>
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>

using namespace std;

// 定义任务结构体
struct Task {
    int priority; // 任务优先级
    int id; // 任务ID
    Task(int p, int i):priority(p), id(i){}
};

// 定义多级队列，分别存放不同优先级的任务
queue<Task> q1; // 优先级1队列
queue<Task> q2; // 优先级2队列
queue<Task> q3; // 优先级3队列

mutex m; // 互斥量，保护队列
condition_variable cv; // 条件变量，用于线程之间的同步

// 定义子线程函数
void child_thread(int id) {
    while(true) {
        unique_lock<mutex> lock(m);

        // 从3个队列中依次取出任务
        if(!q1.empty()) {
            Task t = q1.front();
            q1.pop();
            cout << "Child Thread " << id << " process task " << t.id << " with priority " << t.priority << endl;
        } else if(!q2.empty()) {
            Task t = q2.front();
            q2.pop();
            cout << "Child Thread " << id << " process task " << t.id << " with priority " << t.priority << endl;
        } else if(!q3.empty()) {
            Task t = q3.front();
            q3.pop();
            cout << "Child Thread " << id << " process task " << t.id << " with priority " << t.priority << endl;
        } else {
            // 所有队列都为空，等待新任务到来
            cv.wait(lock);
        }
    }
}

// 定义主函数
int main() {
    // 创建3个子线程
    thread t1(child_thread, 1);
    thread t2(child_thread, 2);
    thread t3(child_thread, 3);

    // 向3个队列中添加任务
    q1.push(Task(1, 1));
    q1.push(Task(1, 2));
    q2.push(Task(2, 3));
    q3.push(Task(3, 4));

    // 通知子线程有新任务到来
    cv.notify_all();

    // 等待子线程完成任务
    t1.join();
    t2.join();
    t3.join();

    return 0;
}

以上代码中，使用了3个优先级队列存放不同优先级的任务，3个子线程从队列中依次取出任务进行处理。当所有队列都为空时，子线程会等待条件变量通知有新任务到来。通过这种方式，子线程之间的同步就得以实现。