夜光序言：
你若光明，世界就不会黑暗；你若心怀希望，世界就不会彻底绝望~~
正文：
import java.util.Scanner;
import java.util.concurrent.Exchanger;
public class ExchangerExample {
/**
*
* 夜光
* 线程之间信息交流~~
* 本例通过Exchanger实现学生成绩查询，简单线程间数据的交换
*
* 核心：大家双方都运行到exchange这句话~~，并且是双向的，项目中会用到~~
*
* @param args
* @throws InterruptedException
*/
public static void main(String[] args) throws InterruptedException {
Exchanger<String> exchanger = new Exchanger<String>();
BackgroundWorker worker = new BackgroundWorker(exchanger);
// 夜光 上面我们定义了一个后台的工作者~~
new Thread(worker).start();
Scanner scanner = new Scanner(System.in);
while(true) {
System.out.println("夜光~~输入要查询的属性学生姓名：");
String input = scanner.nextLine().trim();
exchanger.exchange(input); //夜光 把用户输入传递给线程，下面我们写的代码有一个item~~
String value = exchanger.exchange(null); //夜光 拿到线程反馈结果
if ("exit".equals(value)) {
break;
}
System.out.println("查询结果：" + value);
}
scanner.close();
}
}
class BackgroundWorker implements Runnable {
final Exchanger<String> exchanger;
BackgroundWorker(Exchanger<String> exchanger) {
this.exchanger = exchanger;
}
@Override
public void run() {
while (true) {
try {
String item = exchanger.exchange(null);
switch (item) {
case "Genius":
exchanger.exchange("Top1");// 夜光 对应26行~~exchanger.exchange(input);
break;
case "A":
exchanger.exchange("~~");
break;
case "B":
exchanger.exchange("!!");
break;
case "exit":
exchanger.exchange("exit");
return;
default:
exchanger.exchange("查无此人");
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}