需要关于java中ExecutorService的建议吗

Question

嘿，所以我为ExecutorService的java文档选择了这个例子。我想确认这个代码的流程，执行者。newFixedThreadPool将创建一个线程池（我猜）。所以serversocket将等待连接，一旦获得连接，就会启动一个线程，所以现在池大小减少1。一旦线程完成执行，池大小将再次增加1，不是吗？线程会放弃它使用的资源吗？

class NetworkService implements Runnable {
 private final ServerSocket serverSocket;
 private final ExecutorService pool;

 public NetworkService(int port, int poolSize)
   throws IOException {
 serverSocket = new ServerSocket(port);
 pool = Executors.newFixedThreadPool(poolSize);
}

 public void run() { // run the service
 try {
   for (;;) {
     pool.execute(new Handler(serverSocket.accept()));
   }
 } catch (IOException ex) {
   pool.shutdown();
  }
 }
}

class Handler implements Runnable {
 private final Socket socket;
 Handler(Socket socket) { this.socket = socket; }
 public void run() {
  // read and service request on socket
 }
}

Answer 1

由于它是一个固定的ThreadPool，是的，每次将任务提交到池时池大小都会减小

Answer 2

线程所做的只是执行您的Runnables。
因此，如果您需要在任务完成后进行任何清理，您应该从您的Runnable中进行。池只是一个Producer-消费者模式实现，负责管理线程的生命周期。
线程执行您在队列中传递的任务，因此在您的情况下，套接字不会在线程之间重用。它的范围在Runnable内

Answer 3

一旦线程完成执行，池大小将再次增加1，不是吗？

对线程将执行并运行下一个处理程序。

线程会放弃它使用的资源吗？

不是立即，不是。一旦处理程序run（）方法完成，那么处理程序将超出范围。但是，在释放处理程序实例之前，必须等待垃圾收集器运行。这将依次释放Socket，然后它将成为垃圾收集本身的候选对象。

如果希望更快地释放套接字（我认为这就是问题所在），那么应该在run（）方法的末尾完成。你可以调用socket。close（）（并可能将套接字设置为空）在最后块中。建议采用以下方式：

class Handler implements Runnable {
    ...
    public void run() {
       try {
           // read and service request on socket
       } finally {
           // make sure we close the socket when the handler is finishing
           socket.close();
       }
    }
}