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();}}}
页:
[1]