黑马程序员技术交流社区

标题: 如何实现线程间的通信?总结一下吧 [打印本页]

作者: Joesph    时间: 2013-7-28 06:34
标题: 如何实现线程间的通信?总结一下吧
本帖最后由 杨兴庭 于 2013-8-7 18:07 编辑

如何实现线程间的通信?总结一下吧
作者: 645420297    时间: 2013-8-2 22:26

管道的创建与使用

  





Java

提供了两个特殊的专门的类专门用于处理管道,它们就是

pipedinputstream

类和

pipeoutputstream

类。

  





Pipedinputstream

代表了数据在管道中的输出端,也就是线程向管道读数据的一端;

pipeoutputstream

代表了数据在管道中的输入端,

也就是线程向管道写数据的一端,

这两个

类一起使用可以提供数据的管道流。

  





为了创建一个管道流,我们必须首先创建一个

pipeoutstream

对象,然后,创建

pipeinputstream

对象,实例如下:







pipeout= new pipedyoutstream();  





pipein= new pipedputsteam(pipepout);  

一旦创建了一个管道后,就可以象操作文件一样对管道进行数据的读写。



2

.演示程序:



pipeapp  





应用程序由三个程序组成:主线程(

pipeapp.Java

)及由主线程启动的两个二级线程



ythread.Java



zthread.Java



,

它们使用管道来处理数据。程序从一个内容为一行一行

"x"

字母的

"input.txt"

文件中读取数据,使用管道传输数据,第一次是利用线程

ythread

将数据

"x"

转换为

"y"

,最后利用线程

zthread



"y"

转换为

"z",

之后,程序在屏幕上显示修改后的数

据。

  





主线程





pipeapp.Java



  







main()

方法中,程序首先创建一个应用对象:

pipeapp pipeapp=new pipeapp();  

由于程序中流操作都需要使用

IOException

异常处理,

所以设置了一个

try

块。



try

中,



了从源文件中读取数据,程序为

"input.txt"

文件创建了一个输入流

Xfileln,:





fileinputstream xfileln= new fileinputstream("input.txt");  





新的输入流传递给

changetoy()

方法,让线程

ythread

能读取该文件:







inputstream ylnpipe =pipeapp.changetoy(xfileln);  





changetoy()

方法创建将输入数据

"x"

改变到

"y"

的线程

ythread,

并返回该线程的输入管道:







inputstream zlnpipe = pipeapp.changetoz(ylnpipe);  





changetoz()

方法启动将数据从

"y"

改变到

"z"

的线程

zehread,

主程序将使用从

changetoz()

返回的输入管道。得到以修改的数据。

  





然后,

程序将管道输入流定位到

datainputstream

对象,

使程序能够使用

readline()

方法

读取数据:

  





datainputstream inputstream = new datainputstream(zlnpiepe);  





创建了输入流以后,程序就可以以行一行的读取数据病显示在屏幕上。







String str= inputstream.readline();





While(str!=null){  









system.out.println(str);









str=inputstream.readline();  













}  





显示完成之后,程序关闭输入流:







inputstream.close();





changetoy()

方法

  





changetoy()

方法首先通过传递一个参数

inputstream



datainputstream

对象来定位资源

的输入流,使程序能使用

readline()

方法从流中读取数据:

  





datainputstream xfileln =new datainutstream(inputstream)









然后,

changetoy()

创建输出管道和输入管道:







pipeoutstream pipeout = new pipeoutputstream();  





pipeinputstream pipeln = new pipedinputsteam(pipeout);  





为了能够使用

println()

方法输出修改的后的文本行到管道,程序将输出管道定位到

printstream

对象:

  





printstream printstream = new printstream(pipeout);  





现在,程序可以创建将数据从

x

改变到

y

的线程,该线程是

ythread

类的一个对象,他

传递两个参数:输入文件(

xfileln

)和输出管道(调用

printstream









ythread ythread =new thread(xfileln,printstream);





之后,程序启动线程:







changetoz

()方法

  





changetoz()

方法与

changetoy()

方法很相似,他从

changetoy()

返回的输入流开始:





  

datainputstream yfileln= new datainputstream(inputstream);  





程序创建一个新的管道:

  





pipedoutstream pipeout2 = new pipedoutputstream();  





pipedinputstream pipeln2 = new pipedinputsream(pipeout2);  





该线程通过这个新的管道发出修改后的数据(输入流

pipeln2

)给主程序。



作者: xscn    时间: 2013-8-3 09:05
本帖最后由 xscn 于 2013-8-3 09:06 编辑

在对资源同时进行不同操作的多线程时
一种是在同步代码块中定义while循环保证本方线程醒来再次判断标记,要唤醒对方线程定义notifyAll,因为只用notify,容易出现只唤醒本方线程的情况。导致程序中的所有线程都等待。
另一种是jdk1.5后提供了多线程升级解决方案。
将同步Synchronized替换成现实Lock操作。
将Object中的wait,notify notifyAll,替换成了Condition对象。
Lock:替代了Synchronized
    lock
    unlock
    newCondition()
Condition:替代了Object中 wait notify notifyAll
    await();
    signal();
    signalAll();
Condition对象可以Lock锁进行获取绑定,实现本方只唤醒对方操作。
优势在于,一个锁里可以绑定多个Condition对象。以前同步里面多个线程拥有一个锁,绑定一个对象,等待唤醒操作也只能由这个对象决定;现在锁可以绑定多个对象,进而有多个等待唤醒操作,操作更加灵活,只需要区分Condition对象即可。最大的优点是可以做到本方只唤醒对方的操作。可以在嵌套中使用,不会出现死锁的情况。
作者: taotao    时间: 2013-8-4 10:51
顶楼上!
作者: 心灵之歌    时间: 2013-8-5 20:21
将同步Synchronized替换成现实Lock操作。
将Object中的wait,notify notifyAll,替换成了Condition对象。
Lock:替代了Synchronized
    lock
    unlock
    newCondition()
Condition:替代了Object中 wait notify notifyAll
    await();
    signal();
    signalAll();
Condition对象可以Lock锁进行获取绑定,实现本方只唤醒对方操作。
优势在于,一个锁里可以绑定多个Condition对象。以前同步里面多个线程拥有一个锁,绑定一个对象,等待唤醒操作也只能由这个对象决定;现在锁可以绑定多个对象,进而有多个等待唤醒操作,操作更加灵活,只需要区分Condition对象即可。最大的优点是可以做到本方只唤醒对方的操作。可以在嵌套中使用,不会出现死锁的情况。





欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2