sender.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 Sender extends Thread{
	private Socket sock = null;
    public Sender(Socket s){
	  sock = s;
	}
	public void run()  {
        try {
            
			DataOutputStream out = new DataOutputStream(sock.getOutputStream());
            for(int i=0;i<10;i++){
               out.writeBytes("a CCA message sent.");
			}
        
		}catch(Exception e){
		
		} finally {
			try{
            sock.close();
			}catch(Exception e){
		}
        }

	}
}