SynchronousQueue用例

刺骨的言语ヽ痛彻心扉 2022-02-26 17:54 236阅读 0赞

SynchronousQueue是无缓冲区的阻塞队列，即不能直接向队列中添加数据，会报队列满异常，如下所示：

import java.util.concurrent.SynchronousQueue;
    
    public class SynchronousQueueExp {
    	
    	public static void main(String[] args) {
    		SynchronousQueue<String> sq=new SynchronousQueue<>();
    		String str="aaa";
    		sq.add(str);
    	}
    }

![20190330163250213.png][]

必须在有消费者阻塞等待时生产者才可以向队列中添加数据，这时由阻塞状态的消费者直接获取，相当于没有向队列中添加数据，直接将数据交给了消费者。

import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.TimeUnit;
    
    public class SynchronousQueueExp {
    	
    	public static void main(String[] args) {
    		final SynchronousQueue<String> sq=new SynchronousQueue<>();
    		/*String str="aaa";
    		sq.add(str);*/
    		Thread t1=new Thread(new Runnable() {
    			@Override
    			public void run() {
    				try {
    					while (true) {
    						System.out.println("消费者阻塞等待获取数据...");
    						System.out.println("消费者消费数据："+sq.take());
    					}
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    			}
    		},"t1");
    		
    		Thread t2=new Thread(new Runnable() {
    			@Override
    			public void run() {
    				sq.add("bb");
    			}
    		},"t2");
    		
    		t1.start();
    		try {
    			TimeUnit.SECONDS.sleep(2);
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    		t2.start();
    	}
    }

![20190330163323470.png][]

[20190330163250213.png]: /images/20220226/381fabcc23fe4a7c8fef195d5730aef3.png
[20190330163323470.png]: /images/20220226/5e576c83029b49368fb5fea7edbceca7.png

发表评论取消回复

表情：

评论列表（有 0 条评论，236人围观）

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

相关阅读

相关 Java-并发-SynchronousQueue

转载声明 ***本文大量内容系转载自以下文章，有删改，并参考其他文档资料加入了一些内容：*** * [SynchronousQueue的使用][Synchron...

小鱼儿/ 2024年04月18日 09:01/ 0 赞/ 50 阅读

相关 SynchronousQueue

SynchronousQueue SynchronousQueue是一种特殊的BlockingQueue，它本身没有容量。先调put(e)，线程会阻塞；直到另外一个

痛定思痛。/ 2022年09月04日 02:53/ 0 赞/ 161 阅读

相关 JUC SynchronousQueue 分析

基本介绍 `SynchronousQueue` JUC阻塞队列的一种，队列无实际容量，一个put操作必须等待一个take操作的执行，才会解除阻塞状态。将put考虑为生产者

àì夳堔傛蜴生んèń/ 2022年05月21日 13:30/ 0 赞/ 183 阅读

相关 SynchronousQueue队列

SynchronousQueue 一种没有缓存的队列生产者产生的数据直接会被消费者获取，并消费 package com.bjsxt.base.coll

系统管理员/ 2022年05月14日 06:25/ 0 赞/ 201 阅读

相关 SynchronousQueue

分享一下我老师大神的人工智能教程！零基础，通俗易懂！[http://blog.csdn.net/jiangjunshow][http_blog.csdn.net_jiangju

今天药忘吃喽~/ 2022年04月17日 01:36/ 0 赞/ 202 阅读

相关 SynchronousQueue的简单应用2

转：[http://blog.csdn.net/orgcheng/article/details/7985503][http_blog.csdn.net_orgcheng_ar

Love The Way You Lie/ 2022年04月04日 08:54/ 0 赞/ 182 阅读

相关 SynchronousQueue的简单应用1

使用jdk的原话：一种阻塞队列，其中每个 put 必须等待一个 take，反之亦然。同步队列没有任何内部容量，甚至连一个队列的容量都没有。不能在同步队列上进行 peek，因

傷城~/ 2022年04月04日 08:46/ 0 赞/ 239 阅读

相关 SynchronousQueue用例

SynchronousQueue是无缓冲区的阻塞队列，即不能直接向队列中添加数据，会报队列满异常，如下所示： import java.util.concurrent.

刺骨的言语ヽ痛彻心扉/ 2022年02月26日 17:54/ 0 赞/ 237 阅读

相关阻塞队列（四）：SynchronousQueue

阻塞队列（四）：SynchronousQueue 作为BlockingQueue中的一员，SynchronousQueue与其他BlockingQueue有着不同特性： 1

淩亂°似流年/ 2022年01月26日 06:53/ 0 赞/ 247 阅读

相关 SynchronousQueue使用实例

序本文主要讲一下SynchronousQueue。定义 SynchronousQueue，实际上它不是一个真正的队列，因为它不会为队列中元素维护存储空间。与其他队列...

清疚/ 2021年06月14日 00:47/ 0 赞/ 431 阅读