Java并发编程核心方法与框架
public>private Exchanger<String> exchanger; public ThreadA(Exchanger<String> exchanger) {super();
this.exchanger = exchanger;
}
@Override
public void run() {
try {
System.out.println("A线程获得的值：" + exchanger.exchange("String from threadA"));
System.out.println("threadA end");
} catch (Exception e) {
e.printStackTrace();
}
}
}
public> private Exchanger<String> exchanger;
public ThreadB(Exchanger<String> exchanger) {
super();
this.exchanger = exchanger;
}
@Override
public void run() {
try {
System.out.println("B线程获得的值：" + exchanger.exchange("String from threadB"));
System.out.println("threadB end");
} catch (Exception e) {
e.printStackTrace();
}
}
}
public> public static void main(String[] args) {
Exchanger<String> exchanger = new Exchanger<>();
ThreadA a = new ThreadA(exchanger);
a.setName("A");
ThreadB b = new ThreadB(exchanger);
b.setName("B");
a.start();
b.start();
System.out.println("main end");
}
}
页:
[1]