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

更新時間：2022年10月21日 16:56:47 作者：eson_15

這篇文章主要介紹了Java編程線程同步工具Exchanger的使用實例解析，分享了相關代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下

本文研究的主要是Java編程線程同步工具Exchanger的使用，下面看看具體內(nèi)容。

　　如果兩個線程在運行過程中需要交換彼此的信息，比如一個數(shù)據(jù)或者使用的空間，就需要用到Exchanger這個類，Exchanger為線程交換信息提供了非常方便的途徑，它可以作為兩個線程交換對象的同步點，只有當每個線程都在進入 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í)行任務
		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í)行任務
		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é)果如何：