pipeinputstreamtester.java

接着上次传入一些Java学习中的实验

import java.io.*;
import java.util.*;
class Sender extends Thread{
		private PipedOutputStream out_stream=new PipedOutputStream();
		public PipedOutputStream getPipedOutputStream() {return out_stream;}
		
		public void run(){
			try{
				for(int i=-127;i<=128;i++){
				
					out_stream.write(i);
					yield();
			}
			out_stream.close();
		} catch(Exception e){throw new RuntimeException(e);}
		}
		}
public class PipeInputStreamTester extends Thread{
	private PipedInputStream in_stream;
	public PipeInputStreamTester(Sender sender)throws IOException{
		in_stream=new PipedInputStream(sender.getPipedOutputStream());
		
	}
	public void run(){
		try{
			int data;
			while ((data=in_stream.read())!=-1)
			  System.out.println(data);
			  in_stream.close();
			  
		}catch(Exception e){throw new RuntimeException(e);}
	}
	public static void main(String args[])throws Exception{
		Sender sender=new Sender();
		PipeInputStreamTester tester=new PipeInputStreamTester(sender);
		sender.start();
		tester.start();
	}
	}