Java無制限カウント・セマフォ？

Question

BlockingQueue内のすべての未処理作業が処理されるまでブロックするメソッドを提供する必要があります。

私は、0で始まるカウントされたセマフォでこれを処理できると思っていました。アイテムがキューに追加され、それらが完了すると増分するにつれ減少します。 finish（）はセマフォを取得し、再び解放して終了します。

おそらくreducePermits（）を呼び出すことができます。許可カウントがすでに<になっていれば、これは機能しますか？保護されているので、セマフォークラスを拡張して機能させる必要があります。

私の次善のアイデアは、ループ内のキューの内容をチェックし、チェックの間に100msほどスリープすることです。それは動作しますが、クルージュのようです。

これは意味がありますか？誰もが簡単で清潔な方法を提案していますか？

TIA、 - Tim。

public MyClass { 
    public class MySemaphore extends Semaphore { 
    public void seize() { 
     reducePermits(1); 
    } 
    } 
    private MySemaphore allDone = new MySemaphore(); 
    void startSomething() { 
    allDone.seize(); 
    } 
    void finishSomething() { 
    allDone.release(); 
    } 
    void finish() { 
    allDone.acquire(); 
    allDone.release(); 
    } 
} 

Answer 1

あなたは、その後、その後、最終的な処理（おそらく先物などを経由して）すべての項目に自分自身を処理呼び出し、drainTo(collection)を呼び出すことにより、キューを排出できます。