pipestrtes.java

用java编写的一些初级代码

import java.io.*;
class Sender extends Thread
{
    private PipedOutputStream out =new PipedOutputStream();
    public PipedOutputStream getOutputStream()
    {return out;}
    public void run()
    {
	String s=new String("aaabbbccc");
	try
	{
	    out.write(s.getBytes());
	    out.close();
	}
	catch(Exception e)
	{	System.out.println(e.getMessage());}
    }
}
class Receiver extends Thread
{
    private PipedInputStream in=new PipedInputStream();
    public PipedInputStream getInputStream()
    {return in;}
    public void run()
    {
	String s=null;
	byte [] buf =new byte[1024];
	try
	{
	    int len=in.read(buf);
	    s = new String(buf,0,len);
	    System.out.println("ee"+s);
	    in.close();
	}
	catch(Exception e)
	{	System.out.println(e.getMessage());}
    }
}
public class PipeStrTes{
    public static void main(String args[]){ 
	File f=new File("c:\\1.txt");
	try
	{
	    Sender t1=new Sender();
	    Receiver t2=new Receiver();
	    PipedOutputStream out = t1.getOutputStream();
	    PipedInputStream in =t2.getInputStream();
	    out.connect(in);
	    t1.start();
	    t2.start();
	}
	catch(Exception e)
	{	System.out.println(e.getMessage());}
    }
}