多线程学习笔记三

/**
* 两个线程进行数据交换
*
* @time 上午11:19:36
* @author retacn yue
* @Email [e-mail]
*/
@SuppressWarnings("unchecked")
public class ExchangerTest {


/**
* @param args
*/
public static void main(String[] args) {
exchange();
}


/**
*
*/
@SuppressWarnings("rawtypes")
private static void exchange() {
ExecutorService pool = Executors.newCachedThreadPool();
final Exchanger exchanger = new Exchanger();


pool.execute(new Runnable() {


@Override
public void run() {
try {
Thread.sleep((long) (Math.random() * 1000));
String temp = "retacn yue";
System.out.println("线程" + Thread.currentThread().getName() + "正在把数据" + temp + "换出去");
String temp2 = (String) exchanger.exchange(temp);
System.out.println("线程" + Thread.currentThread().getName() + "换为的数据为" + temp2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
pool.execute(new Runnable() {


@Override
public void run() {
try {
Thread.sleep((long) (Math.random() * 1000));
String temp = "zhang san";
System.out.println("线程" + Thread.currentThread().getName() + "正在把数据" + temp + "换出去");
String temp2 = (String) exchanger.exchange(temp);
System.out.println("线程" + Thread.currentThread().getName() + "换为的数据为" + temp2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
}