JavaのBlockingQueueの使い方は？

2年 ago
陽, 向宇
1 minute

BlockingQueueは、Javaの並行パッケージの1つであり、生産者-消費者パターンを実装するためのインタフェースです。要素の追加、削除、およびキュー内の要素の表示など、スレッドセーフなキュー操作を提供します。

BlockingQueueを使用する基本的な手順は以下の通りです：

  1. BlockingQueueオブジェクトを作成します。ArrayBlockingQueue、LinkedBlockingQueueなど、一般的な実装クラスがあります。
BlockingQueue<String> queue = new ArrayBlockingQueue<>(10);
  1. 「put()」を日本語で言い換えると、「置く」です。
Thread producer = new Thread(() -> {
    try {
        queue.put("element");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
});
producer.start();
  1. 取る
Thread consumer = new Thread(() -> {
    try {
        String element = queue.take();
        // 处理元素
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
});
consumer.start();

put()メソッドやtake()メソッドを使用する際、キューが満材や空の場合、スレッドはブロックされ、空間ができるか要素を操作できるまで待機します。

put()メソッドやtake()メソッド以外にも、BlockingQueueにはoffer()メソッドやpoll()メソッドなどの他の方法も提供されています。具体的なニーズに合った方法を選択することができます。

BlockingQueueを使用する際には、InterruptedExceptionを処理する必要があることに注意する必要があります。なぜなら、スレッドがブロックされている間に割り込まれる可能性があるからです。

bannerAds