package demo;
class Message{
private String info;
public void setInfo(String info) {
this.info = info;
}
public String getInfo() {
return info;
}
}
class Channel{ //消息的发送通道
private Channel() {};
//ThreadLocal类，通过给每个线程分配自己的数据空间，可以避免并发线程使用同一资源时发生覆盖
private static final ThreadLocal<Message> THREADLOCAL = new ThreadLocal<Message>();
public static void setMessage(Message msg) {
THREADLOCAL.set(msg);
}
public static void send() {
System.out.println("["+Thread.currentThread().getName()+"]"+THREADLOCAL.get().getInfo());
}
}
public class Demo {
public static void main(String[] args) {
new Thread(()->{
Message msg =new Message();
msg.setInfo("A的消息");
Channel.setMessage(msg);
Channel.send();
},"线程A").start();
new Thread(()->{
Message msg =new Message();
msg.setInfo("B的消息");
Channel.setMessage(msg);
Channel.send();
},"线程B").start();
new Thread(()->{
Message msg =new Message();
msg.setInfo("C的消息");
Channel.setMessage(msg);
Channel.send();
},"线程C").start();
}
}
图片.png
