亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

Java中的SynchronousQueue阻塞隊列使用代碼實例

 更新時間:2023年12月14日 10:04:06   作者:Terisadeng  
這篇文章主要介紹了Java中的SynchronousQueue阻塞隊列使用代碼實例,SynchronousQueue是無緩沖區(qū)的阻塞隊列,即不能直接向隊列中添加數據,會報隊列滿異常,需要的朋友可以參考下

SynchronousQueue阻塞隊列

SynchronousQueue是無緩沖區(qū)的阻塞隊列,即不能直接向隊列中添加數據,會報隊列滿異常,如下所示:

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

必須在有消費者阻塞等待時生產者才可以向隊列中添加數據,這時由阻塞狀態(tà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("消費者阻塞等待獲取數據...");
						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();
	}
}

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

相關文章

  • springboot之Duration(java.time.Duration)在yml properties中的配置方式

    springboot之Duration(java.time.Duration)在yml properties中

    這篇文章主要介紹了springboot之Duration(java.time.Duration)在yml properties中的配置方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-12-12
  • Java獲取視頻時長、大小的示例

    Java獲取視頻時長、大小的示例

    這篇文章主要介紹了Java獲取視頻時長、大小的示例,幫助大家利用Java處理視頻,完成需求,感興趣的朋友可以了解下
    2020-11-11
  • SpringBoot_Cache自定義使用SimpleCacheManager方式

    SpringBoot_Cache自定義使用SimpleCacheManager方式

    這篇文章主要介紹了SpringBoot_Cache自定義使用SimpleCacheManager方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2023-07-07
  • 使用springmvc參數接收boolean類型參數的問題

    使用springmvc參數接收boolean類型參數的問題

    這篇文章主要介紹了使用springmvc參數接收boolean類型參數的問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-01-01
  • Redis?+?Java攔截器實現用戶匿名和非匿名訪問

    Redis?+?Java攔截器實現用戶匿名和非匿名訪問

    本文主要介紹了Redis?+?Java攔截器實現用戶匿名和非匿名訪問,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2022-06-06
  • java?Semaphore共享鎖實現原理解析

    java?Semaphore共享鎖實現原理解析

    這篇文章主要為大家介紹了Semaphore共享鎖實現原理解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-01-01
  • java實現數字轉換人民幣中文大寫工具

    java實現數字轉換人民幣中文大寫工具

    這篇文章主要為大家詳細介紹了java實現數字轉換人民幣中文大寫工具,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2019-04-04
  • Intellij?IDEA如何查看所有斷點

    Intellij?IDEA如何查看所有斷點

    這篇文章主要介紹了Intellij?IDEA如何查看所有斷點問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2023-03-03
  • java中set接口使用方法詳解

    java中set接口使用方法詳解

    這篇文章主要為大家詳細介紹了java中set接口使用方法,介紹了Java中Set集合接口實現插入對象不重復的原理,感興趣的小伙伴們可以參考一下
    2016-05-05
  • java實現消息隊列的兩種方式(小結)

    java實現消息隊列的兩種方式(小結)

    本文主要介紹了兩種java實現消息隊列的方式,利用Spring消息模板發(fā)送消息和Apache ActiveMQ官方實例發(fā)送消息,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2018-12-12

最新評論