快捷導(dǎo)航

Java中的SynchronousQueue阻塞隊(duì)列使用代碼實(shí)例

更新時(shí)間：2023年12月14日 10:04:06 作者：Terisadeng

這篇文章主要介紹了Java中的SynchronousQueue阻塞隊(duì)列使用代碼實(shí)例,SynchronousQueue是無緩沖區(qū)的阻塞隊(duì)列,即不能直接向隊(duì)列中添加數(shù)據(jù),會(huì)報(bào)隊(duì)列滿異常,需要的朋友可以參考下

SynchronousQueue阻塞隊(duì)列

SynchronousQueue是無緩沖區(qū)的阻塞隊(duì)列，即不能直接向隊(duì)列中添加數(shù)據(jù)，會(huì)報(bào)隊(duì)列滿異常，如下所示：

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);
	}
}

必須在有消費(fèi)者阻塞等待時(shí)生產(chǎn)者才可以向隊(duì)列中添加數(shù)據(jù)，這時(shí)由阻塞狀態(tài)的消費(fèi)者直接獲取，相當(dāng)于沒有向隊(duì)列中添加數(shù)據(jù)，直接將數(shù)據(jù)交給了消費(fèi)者。

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("消費(fèi)者阻塞等待獲取數(shù)據(jù)...");
						System.out.println("消費(fèi)者消費(fèi)數(shù)據(jù)："+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();
	}
}

到此這篇關(guān)于Java中的SynchronousQueue阻塞隊(duì)列使用代碼實(shí)例的文章就介紹到這了,更多相關(guān)SynchronousQueue阻塞隊(duì)列內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

相關(guān)文章

springboot之Duration(java.time.Duration)在yml properties中
這篇文章主要介紹了springboot之Duration(java.time.Duration)在yml properties中的配置方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2023-12-12
Java獲取視頻時(shí)長(zhǎng)、大小的示例
這篇文章主要介紹了Java獲取視頻時(shí)長(zhǎng)、大小的示例，幫助大家利用Java處理視頻，完成需求，感興趣的朋友可以了解下
2020-11-11
SpringBoot_Cache自定義使用SimpleCacheManager方式
這篇文章主要介紹了SpringBoot_Cache自定義使用SimpleCacheManager方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2023-07-07
使用springmvc參數(shù)接收boolean類型參數(shù)的問題
這篇文章主要介紹了使用springmvc參數(shù)接收boolean類型參數(shù)的問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2022-01-01
Redis?+?Java攔截器實(shí)現(xiàn)用戶匿名和非匿名訪問
本文主要介紹了Redis?+?Java攔截器實(shí)現(xiàn)用戶匿名和非匿名訪問，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2022-06-06
java?Semaphore共享鎖實(shí)現(xiàn)原理解析
這篇文章主要為大家介紹了Semaphore共享鎖實(shí)現(xiàn)原理解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2023-01-01
java實(shí)現(xiàn)數(shù)字轉(zhuǎn)換人民幣中文大寫工具
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)數(shù)字轉(zhuǎn)換人民幣中文大寫工具，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2019-04-04
Intellij?IDEA如何查看所有斷點(diǎn)
這篇文章主要介紹了Intellij?IDEA如何查看所有斷點(diǎn)問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2023-03-03
java中set接口使用方法詳解
這篇文章主要為大家詳細(xì)介紹了java中set接口使用方法，介紹了Java中Set集合接口實(shí)現(xiàn)插入對(duì)象不重復(fù)的原理，感興趣的小伙伴們可以參考一下
2016-05-05
java實(shí)現(xiàn)消息隊(duì)列的兩種方式(小結(jié))
本文主要介紹了兩種java實(shí)現(xiàn)消息隊(duì)列的方式，利用Spring消息模板發(fā)送消息和Apache ActiveMQ官方實(shí)例發(fā)送消息，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2018-12-12