加入一個ServerSocket正在另一個執行緒堵塞accept，那如何停止accept或者關閉Socket？Server socket 設定下超時 setSoTimeout 然後在Listen執行緒中用interrupt其實直接close socket也可以，不過會丟擲異常，我的意思是有什麼比較安全而又簡單的辦法？難道要加一個標誌，然後要關閉的時候把標誌設為stop，然後連線listernSocket？這樣也未免太麻煩了JDK5.0裡面新增了java.util.concurrent包（對於多執行緒的開發建議儘量使用這個包），下面是javadoc裡面的樣例程式碼用法示例下面給出了一個網路服務的簡單結構，這裡執行緒池中的執行緒作為傳入的請求。它使用了預先配置的Executors.newFixedThreadPool(int) 工廠方法：
 
java 程式碼
 
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 
   } 
}

 
下列方法分兩個階段關閉 ExecutorService。第一階段呼叫 shutdown 拒絕傳入任務，然後呼叫 shutdownNow（如有必要）取消所有遺留的任務：

java 程式碼
 
void shutdownAndAwaitTermination(ExecutorService pool) { 
  pool.shutdown(); // Disable new tasks from being submitted 
  try { 
    // Wait a while for existing tasks to terminate 
    if (!pool.awaitTermination(60, TimeUnit.SECONDS)) { 
      pool.shutdownNow(); // Cancel currently executing tasks 
      // Wait a while for tasks to respond to being cancelled 
      if (!pool.awaitTermination(60, TimeUnit.SECONDS)) 
          System.err.println("Pool did not terminate"); 
    } 
  } catch (InterruptedException ie) { 
    // (Re-)Cancel if current thread also interrupted 
    pool.shutdownNow(); 
    // Preserve interrupt status 
    Thread.currentThread().interrupt(); 
  } 
} 

記憶體一致性效果：執行緒中向 ExecutorService 提交 Runnable 或 Callable 任務之前的操作 happen-before 由該任務所提取的所有操作，後者依次 happen-before 通過 Future.get() 獲取的結果。

軟體包 java.util.concurrent