pipestream2.java

这是清华大学编写的JAVA教材中所有题目的源代码！

import java.io.*;

class PipeStream2
{
	public static void main(String args[])
	{
		try
		{
			//创建管道输入流
			PipedReader in = new PipedReader();
			//创建管道输出流
			PipedWriter out = new PipedWriter();
			//输入与输出流相连
			out.connect(in);
			//创建并启动管道输入线程
			Thread t1=new PipeSender(out);
			t1.start();
			//创建并启动管道输出线程
			Thread t2=new PipeReciver(in);
			t2.start();
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
	}
}

//管道输入类
class PipeSender extends Thread
{
	private PipedWriter out;
	
	//构造函数
	PipeSender(PipedWriter out)
	{  this.out = out;	}
	
	public void run()
	{
		try
		{
			out.write("hello world");
			out.close();
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
	}
}

//管道接收类
class PipeReciver extends Thread
{
	private PipedReader in;
	
	//构造方法
	PipeReciver (PipedReader in)
	{  this.in = in;	}
	
	public void run()
	{
		try
		{
			char buf[]=new char[1024];
			int len=in.read(buf);
			in.close();
			System.out.println(new String(buf,0,len));
		}
		catch(IOException e)
		{
			e.printStackTrace();
		}
	}
}