我要评论java.util.concurrent包中的exchanger类可用于两个线程之间交换信息。
可简单地将exchanger对象理解为
一个包含两个格子的容器，通过exchanger方法可以向两个格子中填充信息。
当两个格子中的均被填充时，该对象会自动将两个格子的信息交换，然后返回给线程，从而实现两个线程的信息交换。
示例代码如下：
package test;
import java.util.concurrent.exchanger;
class exchangertest extends thread {
private exchanger<string> exchanger;
private string string;
private string threadname;
public exchangertest(exchanger<string> exchanger, string string,
string threadname) {
this.exchanger = exchanger;
this.string = string;
this.threadname = threadname;
}
public void run() {
try {
system.out.println(threadname + ": " + exchanger.exchange(string));
} catch (interruptedexception e) {
// todo auto-generated catch block
e.printstacktrace();
}
}
}
public class test {
public static void main(string[] args) {
exchanger<string> exchanger = new exchanger<>();
exchangertest test1 = new exchangertest(exchanger, "string1",
"thread-1");
exchangertest test2 = new exchangertest(exchanger, "string2",
"thread-2");
test1.start();
test2.start();
}
}此程序创建了两个线程
线程在执行过程中，调用同一个exchanger对象的exchange方法，进行信息通信，当两个线程均已将信息放入到exchanger对象中时，exchanger对象会将两个线程放入的信息交换，然后返回，该程序的执行结果如下图：
另外需要注意的是，exchanger类仅可用作两个线程的信息交换，当超过两个线程调用同一个exchanger对象时，得到的结果是随机的，exchanger对象仅关心其包含的两个“格子”是否已被填充数据，当两个格子都填充数据完成时，该对象就认为线程之间已经配对成功，然后开始执行数据交换操作。
修改上文中的示例代码，在第33行之后，再创建一个新线程test3，其中线程名称为thread-3，用于交换的字符串是string3。
即添加如下的代码：
exchangertest test3 = new exchangertest(exchanger, "string3","thread-3"); test3.start();
此时程序的运行结果是不确定的，多次运行可以发现，配对结果可能是test1和test3交换，也可能是test1和test2交换，而剩下的未得到配对的线程，则会被阻塞，永久等待，直到与之配对的线程到达位置，对于本程序，则只能强制将其停止。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持代码网。
发表评论