ExecutorServiceのタイムアウトが期待通りに機能していません

Question

タイムアウトは1秒後に発生するはずですが、そういうことは起こっていません。

public class Worker implements Runnable { 

    int workerId; 

    public Worker(int workerId) { 
     super(); 
     this.workerId = workerId; 
    } 

    public void run() { 
     System.out.println(workerId+"Worker Started ...."); 
     try { 
      Thread.sleep(20000); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
     System.out.println(workerId+"Worker finishes....."); 
    } 
} 

import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.TimeUnit; 

public class TestExecutor { 

    public static void main(String[] args) { 
     ExecutorService executorService=Executors.newCachedThreadPool(); 
     for(int i=0;i<=2;i++){ 
      executorService.submit(new Worker(i)); 
     } 
     executorService.shutdown(); 
     try { 
      executorService.awaitTermination(1, TimeUnit.SECONDS); 
     } catch (InterruptedException e) { 
      System.out.println("Timeout Happen ....."); 
     } 
    } 
} 

Answer 1

このコード

try { 
    executorService.awaitTermination(1, TimeUnit.SECONDS); 
} catch (InterruptedException e) { 
    System.out.println("Timeout Happen ....."); 
} 

は、あなたがそれを行うことを期待しません。

例外：InterruptedExceptionある を - javadocsから

を待っている間に割り込みが発生した場合。 2番目のコードでコードが終了せず、InterruptedExceptionがスローされるのは、コードがexecutorServiceが終了するのを待っている間にスレッドが中断された場合だけです。 executorServiceが実際に終了するかどうかをテストするための正しい待ちが終了するために、スレッドを実行するための

try { 
    if(executorService.awaitTermination(1, TimeUnit.SECONDS)) 
     System.out.println("Terminated correctly"); 
    else 
     System.out.println("Termination failed"); 
} catch (InterruptedException e) { 
    e.printStackTrace(); 
} 

そしてexecutorService.shutdown()待ちだろう。したがって、送信された実行可能ファイルが終了するまで、あなたのコードは20秒間待機し、その間に新しいRunnablesを受け入れたり開始したりすることはありません。 Threadをあまり優雅な方法で終了させたい場合は、executorService.shutdownNow()を使用する必要があります。これは実行中のスレッドを中断させます。