在这段代码中,我要怎么实现【new Thread(new Worker(clientSocket)).start();】用到线程池、而不是每次建立链接都去创建一个新线程。麻烦讲下思路最好把改好代码贴出来看看。
while (true) {
Socket clientSocket;
try {
clientSocket = serverSocket.accept();
logger.info("receive socket " + clientSocket.getInetAddress().getHostName());
new Thread(new Worker(clientSocket)).start();
} catch (IOException e) { // TODO Auto-generated catch block
// e.printStackTrace();
}
}
使用线程池, jdk自带
比如:
//创建一个使用单个 worker 线程的 Executor,以无界队列方式来运行该线程。
ExecutorService pool = Executors.newSingleThreadExecutor();
Thread t1 = new MyThread();
Thread t2 = new MyThread();
// 将线程放入池中进行执行
pool.execute(t1);
pool.execute(t2);
// 最后执行完毕关闭线程池
pool.shutdown();