Java編程線程同步工具Exchanger的使用實(shí)例解析
本文研究的主要是Java編程線程同步工具Exchanger的使用,下面看看具體內(nèi)容。
如果兩個線程在運(yùn)行過程中需要交換彼此的信息,比如一個數(shù)據(jù)或者使用的空間,就需要用到Exchanger這個類,Exchanger為線程交換信息提供了非常方便的途徑,它可以作為兩個線程交換對象的同步點(diǎn),只有當(dāng)每個線程都在進(jìn)入 exchange ()
方法并給出對象時,才能接受其他線程返回時給出的對象。
每次只能兩個線程交換數(shù)據(jù),如果有多個線程,也只有兩個能交換數(shù)據(jù)。下面看個通俗的例子:一手交錢一首交貨!
public class ExchangerTest { public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final Exchanger exchanger = new Exchanger(); //定義一個交換對象,用來交換數(shù)據(jù) //開啟一個線程執(zhí)行任務(wù) service.execute(new Runnable(){ @Override public void run() { try { String data1 = "海"; System.out.println("線程" + Thread.currentThread().getName() + "正在把品" + data1 + "拿出來"); Thread.sleep((long)(Math.random()*10000)); //把要交換的數(shù)據(jù)傳到exchange方法中,然后被阻塞,等待另一個線程與之交換。返回交換后的數(shù)據(jù) String data2 = (String)exchanger.exchange(data1); System.out.println("線程" + Thread.currentThread().getName() + "用海換來了" + data2); } catch(Exception e){ } finally { service.shutdown(); System.out.println("交易完畢,拿著錢快跑!"); } } } ); //開啟另一個線程執(zhí)行任務(wù) service.execute(new Runnable(){ @Override public void run() { try { String data1 = "300萬"; System.out.println("線程" + Thread.currentThread().getName() + "正在把" + data1 +"拿出來"); Thread.sleep((long)(Math.random()*10000)); String data2 = (String)exchanger.exchange(data1); System.out.println("線程" + Thread.currentThread().getName() + "用300萬弄到了" + data2); } catch(Exception e){ } finally { service.shutdown(); System.out.println("交易完畢,拿著海快跑!"); } } } ); } }
從代碼中我仿佛看到了兩個人在交易品的場面……來看一下交易結(jié)果如何:
線程pool-1-thread-1正在把品海拿出來
線程pool-1-thread-2正在把300萬拿出來
線程pool-1-thread-2用300萬弄到了海
線程pool-1-thread-1用海換來了300萬
交易完畢,拿著??炫?!
交易完畢,拿著錢快跑!
跑的倒是快,從運(yùn)行結(jié)果來看,確實(shí)實(shí)現(xiàn)了數(shù)據(jù)的交換,這個只是交換一個基本類型的數(shù)據(jù)而已,它真正的用處不僅僅局限于此,比如我們可以交換一個對象,這就有用了,JDK官方提到了一個高級的應(yīng)用:
使用 Exchanger 在線程間交換緩沖區(qū),因此,在需要時,填充緩沖區(qū)的線程獲取一個新騰空的緩沖區(qū),并將填滿的緩沖區(qū)傳遞給騰空緩沖區(qū)的線程。
這就得根據(jù)實(shí)際情況了,思想和上面的一樣,實(shí)際中肯定要定義一個緩沖區(qū)的類,然后兩個線程之間交換的就是這個緩沖區(qū)的類即可,至于類中如何實(shí)現(xiàn),就得看實(shí)際情況了。Exchanger的使用就總結(jié)這么多吧~
總結(jié)
以上就是本文關(guān)于Java編程線程同步工具Exchanger的使用實(shí)例解析的全部內(nèi)容,希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關(guān)專題,如有不足之處,歡迎留言指出。感謝朋友們對本站的支持!
相關(guān)文章
SpringBoot 使用 Ehcache 作為緩存的操作方法
這篇文章主要介紹了SpringBoot 如何使用 Ehcache 作為緩存,我們通過添加 Ehcache 依賴、創(chuàng)建 Ehcache 配置文件并在 Spring Boot 應(yīng)用程序的配置文件中啟用 Ehcache 緩存,來配置 Ehcache 緩存,需要的朋友可以參考下2023-06-06Eclipse設(shè)置svn忽略文件或文件夾(svn:ignore)的操作
這篇文章主要介紹了Eclipse設(shè)置svn忽略文件或文件夾(svn:ignore)的操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-01-01Spring Security+JWT實(shí)現(xiàn)認(rèn)證與授權(quán)的實(shí)現(xiàn)
本文主要介紹了Spring Security+JWT實(shí)現(xiàn)認(rèn)證與授權(quán)的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04Java中synchronized關(guān)鍵字修飾方法同步的用法詳解
synchronized可以用來同步靜態(tài)和非靜態(tài)方法,下面就具體來看一下Java中synchronized關(guān)鍵字修飾方法同步的用法詳解:2016-06-06Java基于socket實(shí)現(xiàn)簡易聊天室實(shí)例
這篇文章主要介紹了Java基于socket實(shí)現(xiàn)簡易聊天室的方法,實(shí)例分析了java基于socket實(shí)現(xiàn)聊天室服務(wù)端與客戶端的相關(guān)技巧,需要的朋友可以參考下2015-05-05在Java的Hibernate框架中對數(shù)據(jù)庫數(shù)據(jù)進(jìn)行查詢操作
這篇文章主要介紹了Java的Hibernate框架中對數(shù)據(jù)庫數(shù)據(jù)進(jìn)行查詢操作的方法,Hibernate是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-12-12使用OpenFeign實(shí)現(xiàn)服務(wù)調(diào)用的方法詳解
OpenFeign是運(yùn)行在客戶端的聲明式服務(wù)調(diào)用的框架,通過聲明接口的方式來達(dá)到對服務(wù)的調(diào)用,本文就來和大家講講如何使用OpenFeign實(shí)現(xiàn)服務(wù)調(diào)用吧2023-06-06