1. BlockingQueueの使用は、Javaプロデューサー - 消費者モデルを実裝するための最も直接的で推奨される方法です。スレッドの同期を內部的に処理します。プロデューサーは、Put（）メソッドを呼び出して待機キュースペースをブロックし、消費者はTake（）メソッドを呼び出して待機データをブロックします。 2.手動の実裝で同期ロックを必要とし、スレッド動作を調整するためにメカニズムを待機/通知する必要がある場合、コアは條件を確認し、同期ブロック內で共有バッファーを操作することです。 3。ノートには、割り込みの正しい取り扱い、notifyall（）を選択するためのマルチスレッドウェイクアップ戦略、合理的なバッファサイズの設定、エレガントなクロージングスレッドが含まれます。

Java MultiThreadedプログラミングでは、プロデューサー消費者モデルの実裝は一般的な並行性モデルです。これは主に複數のスレッド間のコラボレーションの問題を解決するために使用されます。1つまたは複數のスレッドがデータの「生産」に責任を負い、別のスレッドがこのデータを「消費」する責任があります。

このモデルを実裝するために、キーはスレッド間でデータを安全に渡し、リソースの競爭とデッドロックの問題を回避する方法です。いくつかの実用的な観點から始めて、それを詳細に行う方法について話しましょう。

BlockingQueueを使用することが最も直接的な方法です

Javaは、既製のBlockingQueueインターフェイス（ ArrayBlockingQueueやLinkedBlockingQueueなど）を提供します。これは、スレッド同期問題を內部的に処理し、プロデューサー消費者を実裝するための最も推奨される方法です。

使用は非常に簡単です：

• プロデューサーはput()メソッドを呼び出してキューにデータを配置します
• 消費者は、キューからデータを取得するためにtake()メソッドを呼び出します

両方の方法がブロックされており、キューがいっぱいになると、プロデューサーは待ちます。キューが空の場合、消費者は待機します。これは、目的の動作とまったく同じです。

サンプルコードスニペット：

 blockingqueue <integer> queue = new arrayblockingqueue <>（10）;

//プロデューサースレッド新しいスレッド（（） - > {
    試す {
        int i = 0;
        while（true）{
            queue.put（i）;
            system.out.println（ "生成：" i）;
        }
    } catch（arternedexception e）{
        thread.currentThread（）。
    }
}）。始める（）;

//消費者スレッド新しいスレッド（（） - > {
    試す {
        while（true）{
            int value = queue.take（）;
            System.out.println（ "消費："値）;
        }
    } catch（arternedexception e）{
        thread.currentThread（）。
    }
}）。始める（）;

既製のキューを使用しない場合は、ロックコントロールを手動で追加できます

BlockingQueueに頼りたくない場合は、ロジックを手動で実裝することもできます。この時點で、 synchronizedキーワードとwait/notifyメカニズムを使用して、スレッドの動作を調整する必要があります。

核となるアイデア：

• バッファーとして共有データ構造（ Listなど）を使用します
• バッファーを操作するときにロックします
• バッファがいっぱいになると、プロデューサーのスレッドが待機します。スペースがあると目を覚まします
• バッファが空の場合、消費者のスレッドが待機します。新しいデータが利用可能になると目覚めます

注：

• 誤った目覚めがある可能性があるため、條件をループで確認する必要があります
• wait()とnotify()を呼び出して、同期ブロックで実行する必要があります

例pseudocode：

パブリッククラスSharedBuffer {
    プライベートリスト<Integer>バッファ= new ArrayList <>（）;
    プライベートファイナルint max_size = 10;

    public同期void put（int value）arturtedexception {
        while（buffer.size（）== max_size）{
            待って（）;
        }
        buffer.add（value）;
        notifyall（）;
    }

    public synchronized int take（）throws arturnedexception {
        while（buffer.isempty（））{
            待って（）;
        }
        int value = buffer.remove（0）;
        notifyall（）;
        返品値。
    }
}

無視しやすいが重要な詳細

• 割り込み処理：スレッドが中斷される場合があります。 InterruptedExceptionをキャプチャし、割り込み狀態(tài)を復元することを忘れないでください。
• マルチプロデューサー/コンシューマーシナリオのモーニング戦略：待機しているスレッドが多數ある場合は、 notify() notifyAll()を使用して、モーニングの欠落を避けてみてください
• 合理的なバッファサイズを設定する：大きすぎるとメモリが無駄になり、小さすぎると頻繁に待つことができます
• エレガントに近いスレッド：ループの出口は、終了條件を処理しない無限ループの代わりにフラグビットを追加することで制御できます

基本的にそれだけです。 BlockingQueue機能を迅速に実裝できますが、手動の実裝は基礎となるメカニズムを理解するのに役立ちます。 2つの方法には、獨自の適用シナリオがあります。適切なツールを選択することにより、安定した効率的な同時プログラムを作成できます。

以上がJavaスレッドを使用したプロデューサー - 消費者パターンの実裝。の詳細內容です。詳細については、PHP 中國語 Web サイトの他の関連記事を參照してください。