receiver.java

java多线程设计模式中的线程池设计模式源码

package S7.A6;

import java.net.Socket;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.BufferedReader;
import java.io.DataOutputStream;

public class Receiver extends Thread{
	private Socket sock = null;
	private BufferedReader in = null;
    public Receiver(Socket s){
	  sock = s;
	  try{
	  in=new BufferedReader(
                   new InputStreamReader(
                       sock.getInputStream()));//输入流
	  }catch(Exception e){
	    try{
			sock.close();
		}catch(Exception ie){
		}
	  }
	}
	public void run()  {
        try {
            
			String str = null;
            while(true){
			  str=in.readLine();
			  System.out.println("receive :"+str);
			}
        
		}catch(Exception e1){
		}finally {
			try{
			if(sock != null)
            sock.close();
			}catch(Exception ee){
		}
        }

	}
}