无法关闭线程池

我想在countDownLatch.getCount()为零时关闭服务器，但不是关闭，而是等待接受套接字连接。这是处理传入TCP请求的服务器代码。无法关闭线程池

public static void start(File configFile, ReplyListener replyListener, CountDownLatch countDownLatch) { 
      try { 
       Server.init(configFile); 
       while (countDownLatch.getCount() != 0) { 
        //try { 
         Server.socket = serverSocket.accept(); 
         Message message = new Message(); 
         message.setSocket(Server.socket); 
         Server.pool.submit(new ServerTaskCallable(message.receive()).setReplyListener(replyListener)); 
        /*} catch (SocketTimeoutException e){ 
         System.out.println("Finished testing"); 
        }*/ 
       } 
       Server.socket.close(); 
       serverSocket.close(); 
       Server.pool.shutdownNow(); 
      } catch (IOException e) { 
       logger.error("Cannot start a server. The server thread will be terminated. Exception: ", e); 
       System.exit(0); 
      } 
     }

这里是线程达姆：

"[email protected]" prio=5 tid=0xe nid=NA runnable 
    java.lang.Thread.State: RUNNABLE 
     at java.net.PlainSocketImpl.socketAccept(PlainSocketImpl.java:-1) 
     at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:404) 
     at java.net.ServerSocket.implAccept(ServerSocket.java:545) 
     at java.net.ServerSocket.accept(ServerSocket.java:513) 
     at model.server.Server.start(Server.java:42) 
     at model.MainTest.lambda$main$3(MainTest.java:30) 
     at model.MainTest$$Lambda$2.2012232625.run(Unknown Source:-1) 
     at java.lang.Thread.run(Thread.java:745) 
     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
     at java.util.concurrent.FutureTask.run(FutureTask.java:266) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
     at java.lang.Thread.run(Thread.java:745) 

"[email protected]" prio=5 tid=0x12 nid=NA waiting 
    java.lang.Thread.State: WAITING 
     at sun.misc.Unsafe.park(Unsafe.java:-1) 
     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) 
     at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) 
     at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) 
     at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
     at java.lang.Thread.run(Thread.java:745)

我怎样才能正确地终止服务器线程池？

来源

2015-12-14 mr.M

你有没有在'ServerSocket' [设置超时（https://docs.oracle.com/javase/8/docs/api/java/net/ServerSocket.html#setSoTimeout-int-）？ –

它有助于终止一个线程池，但我想避免使用timeOut（）（如果它当然可行）。 –

我只能想到两个选项第一个是超时，如上所述，基本上迫使你的代码通过循环每隔一段时间。第二个是中断从某个主线程接受调用的线程。 – Pace

你有两个选择：

通过ServerSocket#setSoTimeout(int)坐落在ServerSocket超时。这会导致accept()每次发生超时时都会抛出一个SocketTimeoutException。您将需要捕捉里面你的循环异常，以确保您的服务器不断侦听连接：

while(countDownLatch.getCount() != 0) { try { socket = serverSocket.accept(); } catch(SocketTimeoutException e) { //timeout occurred! } }

关闭通过ServerSocket#close()的ServerSocket从不同的线程。这将抛出一个SocketAcception，终止accept()呼叫。这个异常可能会被外部的这个循环轻松地退出“监听连接”行为。

来源

2015-12-14 19:36:22

无法关闭线程池

回答

相关问题