java 同步器SynchronousQueue詳解及實(shí)例
同步器簡介
學(xué)習(xí)以來對線程的操作有很大的改觀，從c/c++的mutex到j(luò)ava的各種鎖（當(dāng)然不是嫌麻煩，java讀寫鎖的實(shí)現(xiàn)還是帶來不少好處的，但是sokcet的設(shè)計(jì)我就不敢恭維了，tcp和udp是兩個(gè)類，弄得我現(xiàn)在對udp也不怎么熟悉）。其中最讓我感到特別剛需的設(shè)計(jì)就是同步器，除了countdownlatch,剩下的都比較剛需，cyclicbarrier我現(xiàn)在唯一能感覺他的好用處就是循環(huán)打印a,b，exchanger和SynchronousQueue我一直沒發(fā)現(xiàn)什么作用，兩個(gè)就適合生產(chǎn)者消費(fèi)者問題。以上就是四大同步器，聽說過2個(gè)以上的就很厲害了，有些場合太難想了。
場景思路
這次說最后兩個(gè)用的場景吧，我要做的事情呢，是采集一堆數(shù)據(jù)，然后采集另外的數(shù)據(jù)綜合處理，但是兩個(gè)數(shù)據(jù)是和時(shí)間相關(guān)的，如果順序執(zhí)行的話，那么處理結(jié)果的可信度越低，最初的設(shè)想就是利用異步處理，兩個(gè)數(shù)據(jù)采集同時(shí)進(jìn)行，然后一起處理，futuretask，就作為首選，我的采集信息還是周期性的任務(wù)，必需要用定時(shí)的線程池了，但是這種線程池（別說timer，這個(gè)類更建議用線程池替換）并沒有為異步處理做返回值，我也沒辦法直接獲取處理的數(shù)據(jù)了，無奈的情況下只能用線程來做了，同時(shí)也必須要用同步器來同步了，用手動(dòng)阻塞線程然后喚醒這個(gè)行為實(shí)在是太不可取了，你全喚醒了，可能造成不該運(yùn)行的代碼開始運(yùn)行，喚醒單個(gè)，還得看cpu的調(diào)度，于是想到了exchanger和SynchronousQueue，我最終選取了SynchronousQueue。
SynchronousQueue
其實(shí)就是特殊的阻塞隊(duì)列，特殊就特殊在他最多放一個(gè)元素，而且這個(gè)元素不在特定的時(shí)間消費(fèi)掉就沒了，而且永遠(yuǎn)長度都是0，具體看api就發(fā)現(xiàn)能用的方法沒幾個(gè)，3個(gè)是放入，2個(gè)是取走。
demo
生產(chǎn)者，消息最多存放1分鐘
public void run() {
try {
queue.offer(i++,1,TimeUnit.MINUTES);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("add");
}
消費(fèi)者
System.out.println(queue.poll(1,TimeUnit.SECONDS));
用了這個(gè)同步器，這種定時(shí)生產(chǎn)者消費(fèi)者問題，代碼量就很少，不需要自己再寫同步的代碼了。也避免了最初喚醒阻塞帶來的不可預(yù)估性。
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
相關(guān)文章
這篇文章主要介紹了SpringCloud Stream介紹,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-03-03
SpringCloud Gateway自動(dòng)裝配實(shí)現(xiàn)流程詳解
Spring Cloud Gateway旨在為微服務(wù)架構(gòu)提供一種簡單有效的、統(tǒng)一的 API 路由管理方式。Spring Cloud Gateway 作為 Spring Cloud 生態(tài)系中的網(wǎng)關(guān)，它不僅提供統(tǒng)一的路由方式，并且基于 Filter 鏈的方式提供了網(wǎng)關(guān)基本的功能，例如：安全、監(jiān)控/埋點(diǎn)和限流等2022-10-10
阿里云對象存儲OSS（Object Storage Service）是一款海量、安全、低成本、高可靠的云存儲服務(wù),多種存儲類型供選擇,全面優(yōu)化存儲成本,非常適合存儲非結(jié)構(gòu)化數(shù)據(jù),本文給大家介紹springboot工程使用阿里云OSS傳輸文件的操作,感興趣的朋友一起看看吧2023-08-08
java實(shí)現(xiàn)附件預(yù)覽（openoffice+swftools+flexpaper）實(shí)例
本篇文章主要介紹了java實(shí)現(xiàn)附件預(yù)覽（openoffice+swftools+flexpaper）實(shí)例，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下。2016-10-10
今天小編就為大家分享一篇springMVC中RestTemplate傳值接值方法，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-08-08
這篇文章主要介紹了Spring注解方式無法掃描Service注解的解決方案，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-10-10
這篇文章主要介紹了Maven中jar包沖突原理與解決辦法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
這篇文章主要介紹了Java中ArrayList的8種淺拷貝方式的相關(guān)資料,講解了Java中ArrayList的淺拷貝概念,并詳細(xì)分享了八種實(shí)現(xiàn)淺拷貝的方法,可以幫助讀者更好地理解和選擇合適的淺拷貝方法,需要的朋友可以參考下2025-01-01
Springboot如何實(shí)現(xiàn)代理服務(wù)器
這篇文章主要介紹了Springboot如何實(shí)現(xiàn)代理服務(wù)器問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-06-06
解決springboot+activemq啟動(dòng)報(bào)注解錯(cuò)誤的問題
這篇文章主要介紹了解決springboot+activemq啟動(dòng)報(bào)注解錯(cuò)誤的問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07