定期的にスレッドをブロックするJavaを目覚めさせる

Question

私は、いくつかのスレッドがバッファに書き込んでおり、バッファから読み込んでファイルに書き込むスレッドが1つあるプログラムを持っています。 バッファは、バッファが空のときにエントリを抽出してスレッドをブロックする（wait（）が使用される）ように実装されています。 スレッドは、BufferedStreamを使用してファイルに書き込みます。 現在、ファイルが書き込まれるたびにBufferedStreamをフラッシュしています。

while (true) 
{ 
    BufferEntry entry = buffer.getEntry(); // might block 

    logFile.printf("%s", entry); 

    ++entriesWritten; 

    if (entriesWritten >= 10) 
    { 
     logFile.flush(); 
     entriesWritten = 0; 
    } 
} 

ただし、IはXのエントリ（X < 10）を書き込んだ後、バッファが長時間空のままであるユースケースをカバーしたいと思います。 バッファに残っているエントリが一定時間以上ファイルに書き込まれるようにしたいと思います。

私は、フラッシングを処理するために定期的にウェイクアップするデーモンについて考えていましたが、そのようなデーモンは複数のスレッドがファイルを処理することを意味しますが、これは望ましくありません。デーモンは、現在のフラッシュされていないエントリがいつ書き込まれたのかを知る必要はありません。

私は割り込みメソッドを使用し、InterruptedExceptionをキャッチすることを考えていました。しかし、私はこのアプローチがきわめて簡単ではないことを恐れています。ファイルに書き込むときに受け取った割り込みは、処理が必要な異なる種類の例外を引き起こす可能性があります。

また、バッファコンストラクタをオーバーロードして、バッファが永久にではなく指定された分だけ待機するようにする追加のパラメータを受け取ることをお勧めします。目を覚ますと、フラッシュが必要かどうかを確認することができます。このソリューションの私の懸念は、Bufferに懸念すべきではないものと、waitがブロック解除の理由を示すものではないという事実をBufferに負わせています。

このような状況を処理するにはかなりの方法がありますか？

Answer 1

あなたはCondition

このクラスに見てみたいことは、オブジェクトのモニター・メソッド（wait、notifyとnotifyAll）の機能を提供しています - 彼らが名前の衝突を避けるためにawait、signalとsignalAllと呼ばれていますObjectから継承したメソッド。

はそれが指定された待機時間が経過合図または中断、またはされるまで、現在のスレッドを待機させ：それはあなたがタイムアウトを指定することができますよう

は、あなたが興味を持つであろうことは、方法awaitNanosです。

一方、おそらく単純なObject.wait(long timeout)で十分です。

Answer 2

buffer.getEntry()はObject.wait()と表示されています。別のメソッドbuffer.getEntry(long timeout)を実装して、Object.wait(timeout)を呼び出し、タイムアウトが発生した場合はnullを返します。

 BufferEntry entry = buffer.getEntry(timeout); // might block 

    if (entry != null) { 
     logFile.printf("%s", entry); 
     ++entriesWritten; 
    } 

    if (entriesWritten >= 10 || entry == null) { 
     logFile.flush(); 
     entriesWritten = 0; 
    }