我有以下问题。我的进程生成 4 个线程,它们独立执行相同的任务,需要等待所有线程完成处理才能进入下一个处理迭代。然而,事件线程的数量,即处理数据并需要等待其他线程完成的线程数量是可变的,从 1 到 4。例如,有时 2 个线程将处理数据,它们需要相互等待在继续之前。
我已经读到障碍可以为我做到这一点,但是,在创建它们时,我必须指定要等待的线程数,而我的应用程序并非如此。此外,由于应用程序的实现方式,每次都继续创建/销毁障碍会很尴尬和复杂。
我想知道是否有其他方法可以解决这个问题。
谢谢!
最佳答案
这就是使用 Semaphore 实现它的方法。
// Global Sempahore initialized to zero.
Sempahore global_sempahore(0)
// Your main thread which spawns your 'n' worker thraeds.
// After spawning 'n' threads your main thread will wait for those threads to finish.
for (int i=0; i<n; i++) {
global_sempahore.sem_wait();
}
// This is your worker thread routine.
// After processing the common work routine before exiting each thread will signal the sempahore.
global_sempahore.sem_post();
想法是在锁定模式下用 0 初始化信号量。 在主线程中生成 n 个工作线程后,在 sempahore 上等待 n 次。
在工作线程中,就在退出信号量之前。
这将确保主线程只有在所有 n 个线程都完成执行时才会唤醒。
关于linux - 如何将进程与随机数量的事件线程同步?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53831581/