1

LinkedBlockingQueue(効率的な)ブロッキング待機のセマンティクスを使用して、複数のJavaのインスタンスを1つに多重化するための優れたパターンはありますか?

4

1 に答える 1

4

Java の LinkedBlockingQueue インスタンスの複数を (効率的な) ブロッキング待機のセマンティクスを使用して 1 つに多重化するための適切なパターンはありますか?

入力ごとに 1 つのスレッドLinkedBlockingQueueを呼び出しtake()てから、要素を共有出力に配置しますLinkedBlockingQueue

何かのようなもの:

public void run() {
    while (!Thread.currentThread().isInterrupted()) {
        try {
            outputQueue.put(inputQueue.take());
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
            return;
        }
    }
}

それについて他に何を言うべきかわかりません。

于 2013-07-30T13:52:05.353 に答える