Java中SynchronousQueue队列怎么实现排队

在Java中，SynchronousQueue队列是一种特殊的阻塞队列，其主要特点是只能同时有一个元素在队列中，当一个线程尝试将一个元素放入队列时，它会被阻塞，直到另一个线程尝试从队列中取出该元素。

要实现排队功能，可以使用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队列不存储元素，只是作为线程间通信的中介，因此在使用过程中要确保有其他线程来取出队列中的元素，否则会导致线程一直阻塞。