Javaでキューを使用してどのように同時処理の問題を解決するか

2年 ago
陽, 向宇
1 minute

Javaでは、java.util.concurrentパッケージで提供されるBlockingQueueを使用して、並行処理の問題を解決することができます。

BlockingQueueとは、スレッドセーフなキューであり、キューが空の時に非空になるまで待ったり、キューがいっぱいの時に非いっぱいになるまで待ったりできるブロック操作を提供します。

以下に、BlockingQueue を使った並行問題の解決策の例を 1 つ示します。

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class ConcurrentQueueExample {
    private static BlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();

    public static void main(String[] args) {
        // 创建生产者线程
        Thread producerThread = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    // 向队列中添加元素
                    queue.put(i);
                    System.out.println("Producer: " + i);
                    Thread.sleep(100); // 休眠一段时间
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 创建消费者线程
        Thread consumerThread = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    // 从队列中获取元素
                    int value = queue.take();
                    System.out.println("Consumer: " + value);
                    Thread.sleep(200); // 休眠一段时间
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

        // 启动生产者和消费者线程
        producerThread.start();
        consumerThread.start();
    }
}

本例では LinkedBlockingQueue をキューとして作成し、その後プロデューサースレッドとコンシューマースレッドを作成しました。プロデューサースレッドは put() メソッドでキューに要素を追加し、コンシューマースレッドは take() メソッドでキューから要素を取得します。BlockingQueue のブロッキング特性により、キューが空のときは、コンシューマースレッドはキューに消費可能な要素があるまで待機します。キューがいっぱいのときは、プロデューサースレッドは新しい要素を追加できるスペースがあるまで待機します。

BlockingQueueを使うことで、マルチスレッドにおける同時処理を実現でき、手動でのスレッド同期や排他制御が不要になる。

bannerAds