スレッドをQUEUEする方法はありますか？

Question

バッファフルシミュレーションを実行しようとしています。バッファーがいっぱいになったら、それをさらに処理するためにコピーする必要があります。コピーは相互に排他的な操作ですが、それ以上の処理はできません。 私の動作フローはこのようなもので、条件が真であれば何かを書こうとするたびにバッファの完全な状態をチェックします。現在のバッファをコピーします。&それを処理します。&新しいメッセージを書きます。

私は複数の書き込みスレッド&を持っていますが、メッセージは順番にしか書き込まれません。

bwrite(data) 
{ 
    lock(m1); 
    //invoke copy thread 
    lock(m1); 
    // Do write message 
} 

copy(data) 
{ 
//copy the data 
unlock(m1); 
//Do further processing 
} 

に従ってください問題は、コピーが完了したらthread01コピーが最初に私はいけない場合thread01、& thread02が&がある場合、メッセージは例えばのような任意の順序で書かれているということであるとして簡単なの私の機能がありますthread01が最後のメッセージを書き込む前にthread02がコピーを開始する可能性がありますので、メッセージが失われる可能性があります。

私は次の実行シーケンスを保証できるように、基本的には待ち行列に入ってくるスレッドを入れる方法が必要です。

Answer 1

はい、セマフォを使用しhttp://en.wikipedia.org/wiki/Semaphore_%28programming%29

Answer 2

なぜあなただ​​けのスレッドが共有キューに書き込みを持っていないのですか？次に、別のスレッドがキューから要素を1つずつ取り出して書き込むようにすることができます。これにより、キューに入れられた順序と同じ順序で書き込まれることが保証されます。これで、スレッドセーフにするためにキューへのアクセスを同期させるだけで済みます。

Answer 3

実際、私はこれに最も適したソリューションはBlockingQueueを使用することだと考えています。私はあなたが誰かがそれのためのサンプルC + +のコードを投稿していることを見つけることができます私は確信していますが、ここでは、Javaの使用法のサンプルですhttp://download.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/BlockingQueue.html