java高級---->Thread之Exchanger的使用

　　Exchanger可以在兩個線程之間交換數據，只能是2個線程，他不支持更多的線程之間互換數據。今天我們就通過實例來學習一下Exchanger的用法。

 

Exchanger的簡單實例

　　Exchanger是在兩個任務之間交換對象的柵欄，當這些任務進入柵欄時，它們各自擁有一個對象。當他們離開時，它們都擁有之前由對象持有的對象。它典型的應用場景是：一個任務在創建對象，這些對象的生產代價很高昂，而另一個任務在消費這些對象。通過這種方式，可以有更多的對象在被創建的同時被消費。

一、Exchanger的簡單使用

package com.linux.huhx.concurreny;

import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ExchangerTest {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newCachedThreadPool();
        final Exchanger exchanger = new Exchanger();
        executor.execute(new Runnable() {
            String data1 = "Ling";

            @Override
            public void run() {
                doExchangeWork(data1, exchanger);
            }
        });

        executor.execute(new Runnable() {
            String data1 = "huhx";

            @Override
            public void run() {
                doExchangeWork(data1, exchanger);
            }
        });
        executor.shutdown();
    }

    private static void doExchangeWork(String data1, Exchanger exchanger) {
        try {
            System.out.println(Thread.currentThread().getName() + "正在把數據 " + data1 + " 交換出去");
            Thread.sleep((long) (Math.random() * 1000));

            String data2 = (String) exchanger.exchange(data1);
            System.out.println(Thread.currentThread().getName() + "交換數據 到  " + data2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

運行結果如下：不固定

pool-1-thread-1正在把數據 Ling 交換出去
pool-1-thread-2正在把數據 huhx 交換出去
pool-1-thread-2交換數據 到  Ling
pool-1-thread-1交換數據 到  huhx

當線程A調用Exchange對象的exchange()方法后，他會陷入阻塞狀態，直到線程B也調用了exchange()方法，然后以線程安全的方式交換數據，之后線程A和B繼續運行。

 

友情鏈接