SynchronousQueue

同步队列

package Juc;import java.util.concurrent.BlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;
/*** 同步队列SynchronousQueue一次只允许一个元素，消费后才插入下个元素进入队列**/
public class SynchronousQueueDemo {public static void main(String[] args) {BlockingQueue<String> bq = new SynchronousQueue<>();new Thread(() -> {try {System.out.println(Thread.currentThread().getName()+"\t put 1");bq.put("1");System.out.println(Thread.currentThread().getName()+"\t put 2");bq.put("2");System.out.println(Thread.currentThread().getName()+"\t put 3");bq.put("3");} catch (Exception e) {e.printStackTrace();}},"aa").start();new Thread(() -> {try {try{TimeUnit.SECONDS.sleep(5);}catch (Exception e){e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"\t "+bq.take());try{TimeUnit.SECONDS.sleep(5);}catch (Exception e){e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"\t "+bq.take());try{TimeUnit.SECONDS.sleep(5);}catch (Exception e){e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"\t "+bq.take());} catch (Exception e) {e.printStackTrace();}},"bb").start();}}

SynchronousQueue相关推荐

java 并发队列_JAVA并发编程：阻塞队列BlockingQueue之SynchronousQueue
前面在讲解Executors工厂创建可缓存线程的线程池(newCachedThreadPool)的时候有提到过SynchronousQueue队列,该线程池使用 SynchronousQueue 作为 ...
java并发之SynchronousQueue实现原理
前言 SynchronousQueue是一个比较特别的队列,由于在线程池方面有所应用,为了更好的理解线程池的实现原理,笔者花了些时间学习了一下该队列源码(JDK1.8),此队列源码中充斥着大量的CAS ...
SynchronousQueue队列
SynchronousQueue 一种没有缓存的队列生产者产生的数据直接会被消费者获取,并消费 package com.bjsxt.base.coll013;import java.util.Ar ...
synchronousqueue场景_java并发队列之SynchronousQueue
特点:阻塞队列,此队列有点特殊,没有存储空间,也就是不存储数据.每一个put操作必须等待一个take操作,反之,每一个take操作也必须等待一个put操作.如果put进去一个数据,那么必须等待这条数据 ...
[源码]解析 SynchronousQueue 上界,下界.. 数据保存和数据传递. 堵塞队列. 有无频繁await?...
简析SynchronousQueue.LinkedBlockingQueue(两个locker,更快),ArrayBlockingQueue(一个locker,读写都竞争) 三者都是blockingQ ...
SynchronousQueue详解
文章目录简介举例说明总结 SynchronousQueue详解简介 SynchronousQueue是BlockingQueue的一种,所以SynchronousQueue是线程安全的.Syn ...
java多线程之：SynchronousQueue队列
转载自 java多线程之:SynchronousQueue队列 SynchronousQueue是这样一种阻塞队列,其中每个 put 必须等待一个 take,反之亦然.同步队列没有任何内部容量,甚至 ...
Java中的SynchronousQueue示例–生产者使用者解决方案
SynchronousQueue是BlockingQueue的一种特殊类型,其中每个插入操作必须等待另一个线程进行相应的删除操作,反之亦然. 当您在SynchronousQueue上调用put()方法 ...
使用SynchronousQueue实现生产者/消费者
Java提供了许多用于并发支持的有用类中,有一个我想谈一谈: SynchronousQueue . 特别是,我想通过使用方便的SynchronousQueue作为交换机制来完成Producer / C ...
线程池三种队列使用,SynchronousQueue,LinkedBlockingQueue,ArrayBlockingQueue
使用方法: private static ExecutorService cachedThreadPool = new ThreadPoolExecutor(4, Runtime.getRuntime ...

SynchronousQueue

SynchronousQueue相关推荐

最新文章

热门文章