黑马程序员技术交流社区

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

---

作者: Joesph    时间: 2013-7-28 06:34
标题: 如何实现线程间的通信？总结一下吧


如何实现线程间的通信？总结一下吧

---

作者: 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


在对资源同时进行不同操作的多线程时
一种是在同步代码块中定义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