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交换数据 到  Lingpool-1-thread-1交换数据 到  huhx

当线程A调用Exchange对象的exchange()方法后，他会陷入阻塞状态，直到线程B也调用了exchange()方法，然后以线程安全的方式交换数据，之后线程A和B继续运行。

友情链接

转载于:https://www.cnblogs.com/huhx/p/baseusejavaExchanger.html

你可能感兴趣的文章