Java线程队列的使用-SynchronousQueue

- 日理万妓 2023-10-12 23:11 22阅读 0赞

SynchronousQueue是一种特殊的阻塞队列，它没有容量，也就是说每个插入操作必须等待一个获取操作，反之亦然。它不存储元素，而是直接将元素传递给消费者线程。它可以选择是否需要公平性。如果公平参数被设置为true，那么线程将会按照FIFO的顺序访问队列；否则，访问顺序是不确定的。

SynchronousQueue可以用于实现线程间的同步交换，例如下面的代码创建了一个SynchronousQueue，并在两个线程之间传递一个字符串。

import java.util.concurrent.SynchronousQueue;
    
    public class SynchronousQueueDemo {
        public static void main(String[] args) {
            // 创建一个同步阻塞队列
            SynchronousQueue<String> sq = new SynchronousQueue<>();
            // 创建一个生产者线程，向队列中插入一个字符串
            new Thread(() -> {
                try {
                    System.out.println("Trying to put hello into queue");
                    sq.put("hello");
                    System.out.println("Successfully put hello into queue");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }, "producer").start();
            // 创建一个消费者线程，从队列中获取一个字符串
            new Thread(() -> {
                try {
                    System.out.println("Trying to take from queue");
                    String s = sq.take();
                    System.out.println("Successfully take " + s + " from queue");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }, "consumer").start();
        }
    }

输出结果：

Trying to put hello into queue
    Trying to take from queue
    Successfully take hello from queue
    Successfully put hello into queue

可以看到，生产者线程在插入字符串后被阻塞，直到消费者线程从队列中获取了字符串。同样地，消费者线