Java多线程通信实现方式详解
这篇文章主要介绍了Java多线程通信实现方式详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
线程通信的方式：
1、共享变量
线程间通信可以通过发送信号，发送信号的一个简单方式是在共享对象的变量里设置信号值。线程A在一个同步块里设置boolean型成员变量hasDataToProcess为true，线程B也在同步代码块里读取hasDataToProcess这个成员变量。这个简单的例子使用了一个持有信号的对象，并提供了set和get方法。
publicclassMySignal1{
//共享的变量
privatebooleanhasDataToProcess=false;
//取值
publicbooleangetHasDataProcess(){
returnhasDataToProcess;
}
//存值
publicvoidsetHasDataToProcess(booleanhasDataToProcess){
this.hasDataToProcess=hasDataToProcess;
}
publicstaticvoidmain(String[]args){
//同一个对象
finalMySignal1my=newMySignal1();
//线程1设置hasDataToProcess值为true
finalThreadt1=newThread(newRunnable(){
@Override
publicvoidrun(){
my.setHasDataToProcess(true);
}
});
t1.start();
//线程2取这个值hasDataToProcess
Threadt2=newThread(newRunnable(){
@Override
publicvoidrun(){
try{
//等待线程1完成后取值
t1.join();
}catch(InterruptedExceptione){
e.printStackTrace();
}
my.getHasDataProcess();
System.out.println("t1改变以后的值："+my.getHasDataProcess());
}
});
t2.start();
}
}
运行结果如下：
t1改变以后的值：true
2、等待/唤醒(wait/notify)机制
以资源为例，生产者生产一个资源，通知消费者就消费掉一个资源，生产者继续生产资源，消费者消费资源，以此循环，代码如下。
importsun.security.util.Password;
//资源类
classResource{
privateStringname;
privateintcount=1;
privatebooleanflag=false;
publicsynchronizedvoidset(Stringname){
//生产资源
while(flag){
try{
//线程等待
wait();
}catch(InterruptedExceptione){
}
}
this.name=name+"----"+count+"+++++";
System.out.println(Thread.currentThread().getName()+"..生产者..."+this.name);
flag=true;
//唤醒等待中的消费者
this.notifyAll();
}
publicsynchronizedvoidout(){
//消费资源
while(!flag){
try{
//线程等待，生产者生产资源
wait();
}catch(InterruptedExceptione){
}
}
System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);
flag=false;
//唤醒消费者，生产资源
this.notifyAll();
}
}
//生产者
classProducerimplementsRunnable{
privateResourcers;
publicProducer(Resourcers){
this.rs=rs;
}
//生产者生产资源
@Override
publicvoidrun(){
while(true){
rs.set("商品");
}
}
}
//消费者消费资源
classConsumerimplementsRunnable{
privateResourcers;
publicConsumer(Resourcers){
this.rs=rs;
}
//消费者消费资源
@Override
publicvoidrun(){
while(true){
rs.out();
}
}
}
publicclassProducerConsumerDemo{
publicstaticvoidmain(String[]args){
Resourcer=newResource();
Producerp=newProducer(r);
Consumerc=newConsumer(r);
Threadt1=newThread(p);
Threadt2=newThread(c);
t1.start();
t2.start();
}
}
运行结果如下：
Thread-0..生产者...商品----1+++++ Thread-1...消费者...商品----1+++++ Thread-0..生产者...商品----1+++++ Thread-1...消费者...商品----1+++++ Thread-0..生产者...商品----1+++++ Thread-1...消费者...商品----1+++++ Thread-0..生产者...商品----1+++++
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。