exchanger的使用

package T616;

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 service = Executors.newCachedThreadPool();

        Exchanger exchanger = new Exchanger();
        service.execute(new Runnable() {
            @Override
            public void run() {
                dow(exchanger, "date1");
            }
        });
        service.execute(new Runnable() {
            @Override
            public void run() {
                dow(exchanger, "date2");
            }
        });
        service.shutdown();
    }

    public static void dow(Exchanger exchanger, String date) {
        try {
            System.out.println(Thread.currentThread().getName() + "-----" + date);
            Thread.sleep((long) (Math.random() * 1000));
            String date1 = (String) exchanger.exchange(date);
            System.out.println(Thread.currentThread().getName() + "-----" + date1);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}