条件变量信号问题

Question

我在汤里。这个想法可能很糟糕，但我确实需要一个解决方案。

• 我有两个条件变量，比如 A 和 B。

• 线程 1、2 和 3 正在等待 A。线程 4 正在等待 B。

• B 将由线程 2 执行 pthread_cond-signal()，即线程 4 将执行 线程2发出信号唤醒。

现在，我有另一个线程 5，它对条件变量 A 进行 pthread_cond_broadcasts()。我需要在线程 4 唤醒之前唤醒所有线程 1、2 和 3。也就是说，如果线程 2 醒来并且 B 上的信号，线程 4 可能会在线程 3 之前醒来，这不是我想要的。

任何指示都将受到高度赞赏。

谢谢

Answer 1

您可以使用条件变量来解决这个问题。不要让线程 4 仅等待线程 2 设置的条件，而是让它等待仅在线程 1、线程 2 和线程 3 的所有完成其操作后设置的条件

pthread_mutex_lock(&thread4_lock);
while (!thread1_flag || !thread2_flag || !thread3_flag)
    pthread_cond_wait(&thread4_cond, &thread4_lock);
pthread_mutex_unlock(&thread4_lock);

/* Thread 4 can continue */

： 1 已经完成了它的工作，它设置了它的部分条件：

pthread_mutex_lock(&thread4_lock);
thread1_flag = 1;
pthread_cond_signal(&thread4_cond);
pthread_mutex_unlock(&thread4_lock);

...对于线程 2 和线程 3 也是如此。线程 4 仅在设置了所有标志后才会继续。

Answer 2

使用 信号量：让线程 1-3 中的每个线程发布信号量，并让线程 4等待信号量而不是条件变量 3 次。

您需要使用 sem_init(3) 或 < a href="http://linux.die.net/man/3/sem_open" rel="nofollow">sem_open(3) 创建信号量，sem_post(3) 发布信号量，sem_wait(3) 等待信号量，然后 sem_destroy(3) （如果使用 sem_init) 或 sem_close(3) 和 sem_unlink(3)（如果使用 sem_open) 来销毁信号量。

Answer 3

为此，请考虑使用 ZeroMQ 的进程内信令。 ZeroMQ 实现了一种消息传递模型，可有效用于协调线程以及进程间或网络消息传递。

有关更多信息：http://api.zeromq.org/2-1-1 :zmq-inproc

下面是使用 ZeroMQ 和 Java 在线程之间进行负载平衡的示例。