複数のスレッドのうちの1つが終了するのを待ちますか？

Question

私はスレッドプールを実装しています。各スレッドで必要とされる作業は1〜10秒のCPUなので、従来のスレッドプールを使用するのはうれしいですし、作業単位ごとに新しいスレッドを作成しても構いません。それは問題ではありません。

N個のワーカースレッドのうちの1つが作業を終了し、より多くの時間（または別の時間を開始する準備ができている状態）がいつマスター制御スレッドに通知されるかを確認したいと思います。私はpthread_joinとpthread_cond_waitを見てきました。 Nの1つを待つ方法はないようです。だから私はマスタースレッドに変数を持たせて、スリープ状態にして作業者に目覚めさせることを考えました。これは、労働者が死ななければ働くようです。しかし、彼らが死ぬと、作業者がコントローラを起こしてから、死ぬまでの間に、私が対処したくないウィンドウがあります。

私はインテルのTBBを見ましたが、必要以上に複雑に見えます。

Microsoft WindowsのPTHREADSからWaitForMultipleObjectsに相当するものはありますか？

Answer 1

これは、条件変数の合理的に簡単な使用例です。

mutexで保護されているアクティブな作業項目の数を整数で表します。さらに、2つの条件変数を持ちます.1つは作業中のワーカースレッドに信号を送るためのもので、もう1つはスレッドが終了したメインスレッドに信号を送るためのものです。次のようなものがあります。

main: 
    set freethreads to numthreads 
    init mutex M, condvars TOMAIN and TOWORKER 
    start N worker threads 
    while true: 
     wait for work item 
     claim M 
     while freethreads == 0: 
      cond-wait TOMAIN, M 
     put work item in queue 
     decrement freethreads 
     cond-signal TOWORKER 
     release M 

worker: 
    init 
    while true: 
     claim M 
     while no work in queue: 
      cond-wait TOWORKER, M 
     get work to local storage 
     release M 
     do work 
     claim M 
     increment freethreads 
     cond-signal TOMAIN 
     release M 

ループは永遠に実行されます。実際には、それらを終了させ、終了/クリーンアップコードを実行するような信号があります。

Answer 2

カウントセマフォの使用について考えましたか？

Answer 3

アーキテクチャの観点からは、スレッドプールの責任があります。作業者とプールの同期が存在する必要があります。

pthread_mutex_lock（）またはカウント用セマフォ（sem_wait（）およびsem_post（））は、このような同期に適しています。

1. initが呼び出すことにより、カウンティングセマフォのプール：それを行う1つの方法は、のように例示することができるsem_init（p_to_sem_t、0、int型のn）;
2. n workerはsem_wait（）;を呼び出してセマフォを取得します。
3. プールは、sem_wait（）;を呼び出してワーカーが戻るのを待ちます。
4. プールはセマフォカウントをチェックして、すべてのワーカーがパークしているかどうかを確認します。
5. ワーカーは、終了時にロックを解除します。sem_post（）;