JavaでSynchronousQueueキューを使用して待ち行列を実装する方法は何ですか。

Javaで、SynchronousQueueは特殊なブロッキングキューであり、主な特徴はキューに同時に1つの要素しか存在できないことです。要素をキューに追加しようとするスレッドは、その要素を取り出そうとする別のスレッドが現れるまでブロックされます。

SynchronousQueueのoffer()メソッドとtake()メソッドを使用することで、キュー機能を実装することができます。

以下は、簡単なサンプルコードです。

import java.util.concurrent.SynchronousQueue;

public class QueueExample {
    private static SynchronousQueue<String> queue = new SynchronousQueue<>();

    public static void main(String[] args) {
        // 创建多个线程
        for (int i = 0; i < 5; i++) {
            Thread thread = new Thread(() -> {
                try {
                    String name = Thread.currentThread().getName();
                    System.out.println(name + " 正在排队...");
                    queue.offer(name); // 将线程名称放入队列
                    System.out.println(name + " 排队成功，开始工作");
                    Thread.sleep(1000);
                    System.out.println(name + " 工作完成，离开队列");
                    queue.take(); // 从队列中取出线程名称
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
            thread.start();
        }
    }
}

この例では、5つのスレッドが作成され、それぞれのスレッドが自分の名前をキューに入れて他のスレッドがそれを取り出すのを待ちます。スレッドがブロックされると、他のスレッドは続行し、ブロックされたスレッドが解放されるまで待ちます。

SynchronousQueueは要素を格納しないため、スレッド間の通信の中継デバイスとしての役割を果たします。したがって、他のスレッドがキューから要素を取り出すことを確認して使用する必要があります。そうしないと、スレッドが常にブロックされる可能性があります。