Blocking キューの Java での実装方法

Java の BlockingQueue インタフェースを使用すると、ブロッキングキューを実装できます。

まず、BlockingQueueインターフェースはjava.util.concurrentパッケージの一部なので、このパッケージをインポートする必要があります。

これらのオブジェクトは適宜なブロッキングキュー実装クラスを使用して作成できます。一般的なブロッキングキュー実装クラスには、ArrayBlockingQueue、LinkedBlockingQueue、SynchronousQueue などがあります。

以下に、ArrayBlockingQueueを使用してブロッキングキューを実装するサンプルコードを示します。

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class BlockingQueueExample {
public static void main(String[] args) {
// 创建一个容量为10的阻塞队列
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
// 创建一个生产者线程
Thread producerThread = new Thread(() -> {
try {
// 生产1到10的数字，并将其放入队列
for (int i = 1; i <= 10; i++) {
queue.put(i);
System.out.println("Produced: " + i);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
// 创建一个消费者线程
Thread consumerThread = new Thread(() -> {
try {
// 从队列中取出数字并消费
while (true) {
int num = queue.take();
System.out.println("Consumed: " + num);
Thread.sleep(2000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
// 启动生产者和消费者线程
producerThread.start();
consumerThread.start();
}
}

このサンプルコードでは、容量 10 の ArrayBlockingQueue オブジェクトが作成され、プロデューサー スレッドとコンシューマー スレッドが作成されます。プロデューサー スレッドは数字を継続的に生成してキューに入れ、コンシューマー スレッドはキューから数字を取得して消費します。キューがいっぱいになると、プロデューサー スレッドは空き容量ができるまでブロックされます。キューが空になると、コンシューマー スレッドはキューから要素が取得できるまでブロックされます。