使用

Question

私はFutures

よう

List<Future<String>> results = executorService.invokeAll(tasks); 

または

Future<String> res = executorService.submit(new SingleWorker()); 
System.out.println(res.get()); 

を使用していた場合、システムが完了するのタスクを待ちます。

上記のステートメントの後にexecutorService.shutdownNow();があったとしても、システムはいつもシステム上の既存のスレッドを強制的に終了させるのか分からないので、システムは決してその行が完了するまで未来はに返されます。 何か不足していますか？それをテストする別のテストケースシナリオはありますか？

will shutdownNowは、Runnableとしか動作しません。つまり、 executorService.submit(new MyRunnable())？

EDIT：

私はいくつかの異なるものを試してみました

A）shutdownNowはinvokeAllでは動作しないことが分かりました。 Future.get then文shutdownNowがブロックされFutureまではCallableの場合（解決された後に存在する場合

B）shutdownNow）。

c）shutdownNowはRunnableと完全に一致します。

テストに書かれた私のコードを以下に示します。

class SingleRunnableWorker implements Runnable { 

    @Override 
    public void run() { 
     System.out.println("SingleRunnableWorker Running.."); 
     try { 
      Thread.sleep(10000); 
      System.out.println("SingleRunnableWorker Running after sleep.."); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    } 

} 

class SingleCallableWorker implements Callable<String> { 

    @Override 
    public String call() throws Exception { 
     System.out.println("SingleCallableWorker Calling.."); 
     Thread.sleep(10000); 
     System.out.println("SingleCallableWorker Calling after sleep.."); 
     return "SingleCallableWorker Calling done"; 
    } 

} 

と、次のように私はそれをテストしてい：

タスクはすべて Callablesある

ExecutorService executorService = Executors.newFixedThreadPool(4); 
/*List<Future<String>> results = */executorService.invokeAll(tasks);//blocks by default 

Future<String> res = executorService.submit(new SingleCallableWorker()); 
//System.out.println(res.get()); //blocks if uncommented 

executorService.submit(new SingleRunnableWorker()); 

executorService.shutdownNow(); 

。

ボトムラインはinvokeAllとFuture.getです。誰かが妥当性を確認できますか？

Answer 1

とCallableあなたがThreadPoolExecutorに投稿したものは、java.util.concrrent.FutureTaskとラップされて実行されます。この場合

、タスクがThread.sleep(10000)によってブロックされたときSingleRunnableWorkerとSingleCallableWorkerの両方で、executorService.shutdownNow()はInterruptedExceptionあるが、すぐにスローさせます。

しかし、

• InterruptedExceptionがSingleRunnableWorker.run()でスローはすぐcatchedとe.printStackTrace()が扱うことを余儀なくさ です。SingleCallableWorker.call()でスロー
• InterruptedExceptionは 、FutureTaskにインナーsyncronizerによってsyncronizerだけ 記録InterruptedExceptionあるとリターンをcatchedされます。 future.get()が呼び出されると、 InterruptedExceptionがExecutionExceptionとしてラップされ、 が再スローされます。