指示一批线程已完成到主线程

如何解决指示一批线程已完成到主线程

我想我错过了有关多程序设计的基本设计模式。 我已经解决了一个问题，但我会说它过于复杂。 在程序启动时，我正在分配一个静态的工作程序池和一个主线程，这些程序在整个程序运行期间都存在。 （下面的伪代码）

void *worker(){
   while(1){
   //perworker mutex lock
   //wait for workerSIGNAL
   //do calculations
   //perworker mutex unlock
   }
}

我的主线程向我的所有工作人员发出信号，当工作人员完成时，他们等待来自主线程的下一个信号。 （下面的伪代码）

void *master(){
  while(1){
    //masterMutex lock
    //wait for masterSignal
    //signal all workerthread to start running
    /*
      SHOULD WAIT FOR ALL WORKER THREADS TO FINISH 
      (that is when workers are done with the calculations,and are waiting for a new signal) 
     */
    //materMutex unlock
  }
}

我的主线程从我代码的另一部分（非线程）获取信号，这意味着仅存在一个主线程。 （下面的伪代码）

double callMaster(){
  //SIGNAL masterThread
  //return value that is the result of the master thread
}

我的问题是，如何使masterthread等待所有工作程序完成（等待下一个workerSignal）？ 我的解决方案非常复杂。 我的工作线程中有一个障碍，它等待所有工作线程完成，然后从我的一个线程（threadId = 0）发出信号，通知我在主线程底部正在等待的workerDone条件。 它可以工作，但不是很漂亮，任何改进的想法都值得赞赏。 谢谢。     

解决方法

        您是否考虑过使用ѭ3http://kernel.org/doc/man-pages/online/pages/man3/pthread_join.3.html？听起来您正在使用信号在线程之间进行通信。虽然这在某些情况下可能是适当的，但我认为在您的情况下，您可能会发现使用pthread_join可以简化代码。 我在下面概述了一些示例伪代码：

//this goes in your main thread
for (int i = 0; i < num_threads; ++i)
    pthread_join(thread_id[i],...

这样，您的主线程将一直阻塞，直到“ 5”数组中的所有线程（工作线程）都终止。     ,        您想使用障碍。屏障以计数ѭ6initialize初始化，并且当任何线程调用

pthread_barrier_wait

时，它将阻塞，直到共有

N

个线程位于

pthread_barrier_wait

，然后它们全部返回并且可以再次使用屏障（具有相同的计数）。 有关详细信息，请参见POSIX中的文档： http://pubs.opengroup.org/onlinepubs/9699919799/functions/pthread_barrier_wait.html     ,        在Java中，您可以在此处使用循环屏障，其初始值等于工作线程的数量。 对该屏障的引用将传递给每个工作线程，在每个工作线程的工作结束时，它们将调用barrier.await（）。 主程序将在屏障处等待await（），直到所有工作线程都达到执行点为止，并将其称为barrier.await（）。 只有当所有工作线程都调用了barrier.await（）时，屏障才会升高，并且main可以继续。 循环屏障与闩锁相似，不同之处在于屏障是周期性的，因此可以不确定地重置。 因此，在主回路处于循环中的情况下，循环屏障是一个更好的选择。