PipedInputStream与PipedOutputStream类

转http://tzj163.blog.163.com/blog/static/1096116792010550539756/ 
PipedInputStream类与PipedOutputStream类用于在应用程序中创建管道通信.一个PipedInputStream实例对象必须和一个PipedOutputStream实例对象进行连接而产生一个通信管道.PipedOutputStream可以向管道中写入数据,PipedIntputStream可以读取PipedOutputStream向管道中写入的数据.这两个类主要用来完成线程之间的通信.一个线程的PipedInputStream对象能够从另外一个线程的PipedOutputStream对象中读取数据.

   PipedInputStream与PipedOutputStream类的编程实例(两个线程间进行通信的实例程序)

import java.io.IOException;
import java.io.PipedOutputStream;

public class Producer extends Thread {
	//生产者是要向外面写数据，所以生产者内部创建PipedOutputStream对象用于向外写数据
	private PipedOutputStream out = new PipedOutputStream();
	public PipedOutputStream getOutPutStream()
	{
		return out;
	}
	@Override
	public void run() {
		String info = "Hello Producer!";
		try {
			out.write(info.getBytes());
			out.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	
}

import java.io.IOException;
import java.io.PipedInputStream;

public class Comsumer extends Thread {
	//消费者是要读取外面的数据，所以消费者内部创建PipedInputStream对象用于读取外面的数据
	private PipedInputStream input =new PipedInputStream();
	public PipedInputStream getInputStream()
	{
		return input;
	}
	@Override
	public void run() {
		byte[] bytes = new byte[1024];
		try {
			int len = input.read(bytes);
			System.out.println("the following message comes from Producer:\n" +new String(bytes ,0,len) );
			input.close();
		} catch (IOException e) {
			e.printStackTrace();
		}

	}
	
}

import java.io.IOException;

public class PipedStreamTest {
	public static void main(String[] args) {
		Producer producer = new Producer();
		Comsumer com = new Comsumer();
		try {
			//用于连接到PipedInputStream上,与in.connect(out)等价,connect方法有异常出现的可能
			producer.getOutPutStream().connect(com.getInputStream());
			producer.start();
			com.start();
		} catch (IOException e) {
			e.printStackTrace();
		}
		
		
	}
}

  PipedWriter和PipedReader类，它用来处理字符文本的管道通信.

使用管道流类，可以实现名个程序模块之间的松耦合通信,这样我们在程序中就可以灵活的将多个这样的模块的输入流与输出流相联，然后以拼装成满足各种应用的程序,而不用对模块内部进行修改.使用管道连接的模块具有强内聚弱耦合的特点,若模块被替换或被拆卸不会影响到其他的模块.

通常，数据由某个线程从 PipedInputStream 对象读取，并由其他线程将其写入到相应的 PipedOutputStream。不建议对这两个对象尝试使用单个线程，因为这样可能死锁线程。