您现在的位置是：课程教程文章
java中SynchronousQueue是什么意思
2023-12-15 21:09课程教程文章 人已围观
本教程操作环境：windows7系统、java10版，DELL G3电脑。
1.概念
SynchronousQueue是一个队列长度为 0 的 BlockingQueue，这样只要上一个入队列的生产者的消息没被消费，之后的生产者就必须等待。如果要保证生产者先后顺序，则需要设置为公平模式。
2.特点
（1）内部容量是0
（2）每次删除操作都要等待插入操作
（3）每次插入操作都要等待删除操作
（4）一个元素，一旦有了插入线程和移除线程，那么很快由插入线程移交给移除线程，这个容器相当于通道，本身不存储元素
（5）在多任务队列，是最快的处理任务方式。
3.实例
package com.example.demo.threadnew;
import java.util.Random;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;
public class QueueT {
public static void main(String[] args) throws InterruptedException {
SynchronousQueue<Integer> queue = new SynchronousQueue<Integer>();
new Product(queue).start();
new Customer(queue).start();
}
static class Product extends Thread {
SynchronousQueue<Integer> queue;
public Product(SynchronousQueue<Integer> queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
int rand = new Random().nextInt(1000);
System.out.println("生产了一个产品：" + rand);
System.out.println("等待三秒后运送出去...");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
try {
queue.put(rand);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(queue.isEmpty());
}
}
}
static class Customer extends Thread {
SynchronousQueue<Integer> queue;
public Customer(SynchronousQueue<Integer> queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
try {
System.out.println("消费了一个产品:" + queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("------------------------------------------");
}
}
}
}以上就是java中SynchronousQueue的有关介绍，作为一种阻塞队列，可以说对待任务的处理是非常认真的，一定会保证之前经手任务的完成。对这种队列感兴趣的，快试试代码的使用操作吧。
课程教程：java中SynchronousQueue是什么意思上一篇：js判断字符串包含某个字符的方法
下一篇：没有了
