Java线程队列的使用-SynchronousQueue

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

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

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

  1. import java.util.concurrent.SynchronousQueue;
  3. public class SynchronousQueueDemo {
  4.     public static void main(String[] args) {
  5.         // 创建一个同步阻塞队列
  6.         SynchronousQueue<String> sq = new SynchronousQueue<>();
  7.         // 创建一个生产者线程，向队列中插入一个字符串
  8.         new Thread(() -> {
  9.             try {
  10.                 System.out.println("Trying to put hello into queue");
  11.                 sq.put("hello");
  12.                 System.out.println("Successfully put hello into queue");
  13.             } catch (InterruptedException e) {
  14.                 e.printStackTrace();
  15.             }
  16.         }, "producer").start();
  17.         // 创建一个消费者线程，从队列中获取一个字符串
  18.         new Thread(() -> {
  19.             try {
  20.                 System.out.println("Trying to take from queue");
  21.                 String s = sq.take();
  22.                 System.out.println("Successfully take " + s + " from queue");
  23.             } catch (InterruptedException e) {
  24.                 e.printStackTrace();
  25.             }
  26.         }, "consumer").start();
  27.     }
  28. }

输出结果：

  1. Trying to put hello into queue
  2. Trying to take from queue
  3. Successfully take hello from queue
  4. Successfully put hello into queue

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

发表评论

表情：
评论列表 （有 0 条评论，75人围观）

还没有评论，来说两句吧...

相关阅读