java线程 管道_Java 线程间通讯（管道流方式）

一、管道流是JAVA中线程通讯的常用方式之一，基本流程如下：

1)创建管道输出流PipedOutputStream pos和管道输入流PipedInputStream pis

2)将pos和pis匹配，pos.connect(pis);

3)将pos赋给信息输入线程，pis赋给信息获取线程，就可以实现线程间的通讯了

packagewyf;importjava.io.IOException;importjava.io.PipedInputStream;importjava.io.PipedOutputStream;public classtestPipeConnection {public static voidmain(String[] args) {/*** 创建管道输出流*/PipedOutputStream pos= newPipedOutputStream();/*** 创建管道输入流*/PipedInputStream pis= newPipedInputStream();try{/*** 将管道输入流与输出流连接 此过程也可通过重载的构造函数来实现*/pos.connect(pis);

}catch(IOException e) {

e.printStackTrace();

}/*** 创建生产者线程*/Producer p= newProducer(pos);/*** 创建消费者线程*/Consumer1 c1= newConsumer1(pis);/*** 启动线程*/p.start();

c1.start();

}

}/*** 生产者线程(与一个管道输入流相关联)

**/

class Producer extendsThread {privatePipedOutputStream pos;publicProducer(PipedOutputStream pos) {this.pos =pos;

}public voidrun() {int i = 0;try{while(true)

{this.sleep(3000);

pos.write(i);

i++;

}

}catch(Exception e) {

e.printStackTrace();

}

}

}/*** 消费者线程(与一个管道输入流相关联)

**/

class Consumer1 extendsThread {privatePipedInputStream pis;publicConsumer1(PipedInputStream pis) {this.pis =pis;

}public voidrun() {try{while(true)

{

System.out.println("consumer1:"+pis.read());

}

}catch(IOException e) {

e.printStackTrace();

}

}

}

程序启动后，就可以看到producer线程往consumer1线程发送数据

consumer1:0consumer1:1consumer1:2consumer1:3

......

二、管道流的缺点：

管道流虽然使用起来方便，但是也有一些缺点

1)管道流只能在两个线程之间传递数据

packagewyf;importjava.io.IOException;importjava.io.PipedInputStream;importjava.io.PipedOutputStream;public classtestPipeConnection {public static voidmain(String[] args) {/*** 创建管道输出流*/PipedOutputStream pos= newPipedOutputStream();/*** 创建管道输入流*/PipedInputStream pis= newPipedInputStream();try{/*** 将管道输入流与输出流连接 此过程也可通过重载的构造函数来实现*/pos.connect(pis);

}catch(IOException e) {

e.printStackTrace();

}/*** 创建生产者线程*/Producer p= newProducer(pos);/*** 创建消费者线程*/Consumer1 c1= newConsumer1(pis);

Consumer2 c2= newConsumer2(pis);/*** 启动线程*/p.start();

c1.start();

c2.start();

}

}/*** 生产者线程(与一个管道输入流相关联)

**/

class Producer extendsThread {privatePipedOutputStream pos;publicProducer(PipedOutputStream pos) {this.pos =pos;

}public voidrun() {int i = 0;try{while(true)

{this.sleep(3000);

pos.write(i);

i++;

}

}catch(Exception e) {

e.printStackTrace();

}

}

}/*** 消费者线程(与一个管道输入流相关联)

**/

class Consumer1 extendsThread {privatePipedInputStream pis;publicConsumer1(PipedInputStream pis) {this.pis =pis;

}public voidrun() {try{while(true)

{

System.out.println("consumer1:"+pis.read());

}

}catch(IOException e) {

e.printStackTrace();

}

}

}class Consumer2 extendsThread {privatePipedInputStream pis;publicConsumer2(PipedInputStream pis) {this.pis =pis;

}public voidrun() {try{while(true)

{

System.out.println("consumer2:"+pis.read());

}

}catch(IOException e) {

e.printStackTrace();

}

}

}

程序启动后输出如下：

consumer1:0consumer1:1consumer1:2consumer1:3consumer2:4consumer2:5consumer1:6

......

线程consumer1和consumer2同时从pis中read数据，当线程producer往管道流中写入一段数据后，每一个时刻只有一个线程能获取到数据，并不是两个线程都能获取到producer发送来的数据，因此一个管道流只能用于两个线程间的通讯。不仅仅是管道流，其他IO方式都是一对一传输。

2)管道流只能实现单向发送，如果要两个线程之间互通讯，则需要两个管道流

可以看到上面的例子中，线程producer通过管道流向线程consumer发送数据，如果线程consumer想给线程producer发送数据，则需要新建另一个管道流pos1和pis1，将pos1赋给consumer1，将pis1赋给producer，具体例子本文不再多说。

总结：

可以看到管道流使用起来很方便，但是制约也很大，具体使用要看实际的需求，如果项目中只有两个线程持续传递消息，那用管道流也很方便，如果项目中有很多个线程之间需要通讯，那还是用共享变量的方式来传递消息比较方便。