91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Java編程線程同步工具Exchanger的使用實例解析

發布時間:2020-08-26 16:18:59 來源:腳本之家 閱讀:159 作者:eson_15 欄目:編程語言

本文研究的主要是Java編程線程同步工具Exchanger的使用,下面看看具體內容。

  如果兩個線程在運行過程中需要交換彼此的信息,比如一個數據或者使用的空間,就需要用到Exchanger這個類,Exchanger為線程交換信息提供了非常方便的途徑,它可以作為兩個線程交換對象的同步點,只有當每個線程都在進入 exchange ()方法并給出對象時,才能接受其他線程返回時給出的對象。

  每次只能兩個線程交換數據,如果有多個線程,也只有兩個能交換數據。下面看個通俗的例子:一手交錢一首交貨!

public class ExchangerTest {
	public static void main(String[] args) {
		ExecutorService service = Executors.newCachedThreadPool();
		final Exchanger exchanger = new Exchanger();
		//定義一個交換對象,用來交換數據
		//開啟一個線程執行任務
		service.execute(new Runnable(){
			@Override
			      public void run() {
				try {
					String data1 = "海洛因";
					System.out.println("線程" + Thread.currentThread().getName() 
					              + "正在把毒品" + data1 + "拿出來");
					Thread.sleep((long)(Math.random()*10000));
					//把要交換的數據傳到exchange方法中,然后被阻塞,等待另一個線程與之交換。返回交換后的數據
					String data2 = (String)exchanger.exchange(data1);
					System.out.println("線程" + Thread.currentThread().getName() + 
					          "用海洛因換來了" + data2);
				}
				catch(Exception e){
				}
				finally {
					service.shutdown();
					System.out.println("交易完畢,拿著錢快跑!");
				}
			}
		}
		);
		//開啟另一個線程執行任務
		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("交易完畢,拿著海洛因快跑!");
				}
			}
		}
		);
	}
}

從代碼中我仿佛看到了兩個人在交易毒品的場面……來看一下交易結果如何:

線程pool-1-thread-1正在把毒品海洛因拿出來
線程pool-1-thread-2正在把300萬拿出來
線程pool-1-thread-2用300萬弄到了海洛因
線程pool-1-thread-1用海洛因換來了300萬
交易完畢,拿著海洛因快跑!
交易完畢,拿著錢快跑!

 跑的倒是快,從運行結果來看,確實實現了數據的交換,這個只是交換一個基本類型的數據而已,它真正的用處不僅僅局限于此,比如我們可以交換一個對象,這就有用了,JDK官方提到了一個高級的應用:

使用 Exchanger 在線程間交換緩沖區,因此,在需要時,填充緩沖區的線程獲取一個新騰空的緩沖區,并將填滿的緩沖區傳遞給騰空緩沖區的線程。

  這就得根據實際情況了,思想和上面的一樣,實際中肯定要定義一個緩沖區的類,然后兩個線程之間交換的就是這個緩沖區的類即可,至于類中如何實現,就得看實際情況了。Exchanger的使用就總結這么多吧~

總結

以上就是本文關于Java編程線程同步工具Exchanger的使用實例解析的全部內容,希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題,如有不足之處,歡迎留言指出。感謝朋友們對本站的支持!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

赤壁市| 炎陵县| 屯留县| 长沙县| 汝州市| 延吉市| 汉沽区| 简阳市| 新沂市| 河北省| 长沙县| 大关县| 灵寿县| 阳城县| 沐川县| 洛扎县| 叶城县| 长治县| 无极县| 曲周县| 文山县| 曲松县| 湛江市| 仁布县| 秦安县| 延吉市| 宁津县| 改则县| 基隆市| 阳西县| 德令哈市| 忻州市| 大港区| 上犹县| 襄樊市| 南康市| 乌审旗| 德阳市| 沽源县| 靖安县| 腾冲县|