技术文章 > java >  java基础 > 正文

java中SynchronousQueue是什么意思

小妮浅浅

在我们讲过其它灵活的队列后,今天要说的这个就有一些特殊,它需要保证上一个队列完成任务后,才会开始新队列的任务。如果之前的任务没完成,后面的队列会一直处于停滞的状态。下面我们就对SynchronousQueue的概念、特点进行讲解,然后就使用的实例带来代码部分展示。

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的有关介绍,作为一种阻塞队列,可以说对待任务的处理是非常认真的,一定会保证之前经手任务的完成。对这种队列感兴趣的,快试试代码的使用操作吧。

免费视频教程
本文原创发布python学习网,转载请注明出处,感谢您的尊重!
相关文章
 java ConcurrentLinkedQueue是什么
 ConcurrentLinkedQueue在java的原理探究
 java中ConcurrentLinkedQueue的入队
 ConcurrentLinkedQueue在java出队分析
 java ConcurrentLinkedQueue的用法整理
 java ConcurrentLinkedQueue元素获取操作
相关视频章节
 网络爬虫
 云端部署Web应用程序视频
 Web应用框架Flask和文件模板
 Web应用程序开发概述
 继承和多态
推荐视频
视频教程分类