java 线程池 socket

import java.net.*;
import java.io.*;
import java.util.concurrent.*;

public class Server{
	private final ExecutorService pool;
	private final ServerSocket serverSocket;
	class Handler implements Runnable{
		private Socket socket;
		public Handler(Socket socket){
			this.socket = socket;
		}
		public void run(){
			InetAddress ia = socket.getInetAddress();
			String addr = ia.getHostAddress();
			int port = socket.getPort();
			System.out.println(addr+":"+port);
                           //读取并处理客户端请求
		}		
	}
	public Server(int port,int poolSize)throws Exception{
		serverSocket = new ServerSocket(port);
		pool = Executors.newFixedThreadPool(poolSize);
		for(;;){
			try{
				pool.execute(new Handler(serverSocket.accept()));
			}catch(Exception e){
				e.printStackTrace();
			}
		}
				
	}	
	public static void main(String[] args){
		try{
			Server server = new Server(9090,20);
		}catch(Exception e){
			e.printStackTrace();
		}
		
	}	
	
}