Javaマルチスレッドブロッキングキューの実装方法

2年 ago
結衣, 春花
1 minute

BlockingQueueインターフェイスを使用すると、Javaでマルチスレッドのブロックキューを実装できます。BlockingQueueはスレッドセーフなキューで、キューが空の場合、要素を取得する操作はキューに利用可能な要素があるまでブロックされます。キューがいっぱいの場合、要素を挿入する操作はキューに空きスペースができるまでブロックされます。

具体的な手順を以下に示します。

  1. ArrayBlockingQueue、LinkedBlockingQueue などを利用して、BlockingQueue オブジェクトを作成できます。
  2. キューに要素を挿入する責任を持つ生産者スレッドを作成し、要素の挿入にはputメソッドを使用し、キューが一杯になるとputメソッドはブロックされます。
  3. キューから要素を取り出すためのコンシューマー スレッドを作成し、要素を取得するために take メソッドを使用し、キューが空のときは take メソッドがブロックされます。
  4. 生産者スレッドとコンシューマーを開始し、スレッドを並行して実行する
  5. 生産者スレッドがキューに連続して要素を挿入し、消費者スレッドがキューから連続して要素を取得し、それらはキューのブロックを通して同期を取ります。

下記のサンプルコードを参照のこと。

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;

public class BlockingQueueExample {
    public static void main(String[] args) {
        // 创建一个容量为10的阻塞队列
        BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
        
        // 创建一个生产者线程
        Thread producer = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    // 向队列中插入元素
                    queue.put(i);
                    System.out.println("生产者插入元素: " + i);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        
        // 创建一个消费者线程
        Thread consumer = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    // 从队列中获取元素
                    int element = queue.take();
                    System.out.println("消费者获取元素: " + element);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        
        // 启动生产者线程和消费者线程
        producer.start();
        consumer.start();
    }
}

上記の例では、Producerスレッドはキューに要素を挿入する責任を負い、Consumerスレッドはキューから要素を取得する責任を負います。キューが空の場合、Consumerスレッドはブロックされ、キューがいっぱいの場合、Producerスレッドはブロックされます。BlockingQueueインターフェースで提供されるputメソッドとtakeメソッドを使用して、スレッド間の同期が実現されます。

bannerAds