ツリー内のすべてのスレッドを停止するには？

Question

メインスレッドでExecutorService.shutdownNow（）を実行しても、すべてのスレッドが停止するわけではありませんが、Thread1またはThread2でExecutorService.shutdownNow（）を実行するとサブスレッドが終了します シャットダウンコマンドを最下位レベルにカスケードする方法はありますか？

 Main thread 
     / \ 
    /  \ 
Thread 1 Thread 2 
| | |  | |  
A B C  D E 

メインスレッドからすべてのスレッドを削除するにはどうすればよいですか？スレッドの子スレッドの中断を処理する方法

CompletionService<Object> completionService = new ExecutorCompletionService<Object>(threadExecutor); 
         List<Future<Object>> futures = new ArrayList<Future<Object>>(); 
         for(MultiThread mt : threadList) 
         { 
         futures.add(completionService.submit(mt)); 
         } 

         while (futures.size() > 0) { 
          Future f = completionService.take(); 
          futures.remove(f); 
          try { 
           Object result = f.get(); 
           System.out.println(result); 
          } catch (Exception e) { 
           System.out.println("Caught exception from one task: " + e.getCause().getMessage() + ". shutdown now!"); 
           threadExecutor.shutdownNow(); 
           break; 
          } 
         } 

をcraeteするスニペットの下に使用して

？ Javadocに基づいて

Answer 1

shutdownNowの リストshutdownNowの（） ： 試みは、実行中のアクティブなタスクすべてを停止するには、待機中のタスクの処理を停止し、実行を待機していたタスクのリストを返します。 このメソッドは、タスクをアクティブに実行して終了するのを待機しません。これを行うにはawaitTerminationを使用します。

実行中のタスクの処理を最善の努力で止めようとしても保証はありません。 たとえば、典型的な実装ではThread.interrupt（）を介してキャンセルされるため、割り込みに応答しないタスクは決して終了しない可能性があります。

Answer 2

ThreadPoolExecutorを使用して、ThreadFactoryのインスタンスを渡すことができます。 ThreadFactoryは、作成された新しいスレッドにそれぞれ関連付けられた固有のThreadGroupを使用します。すべてのスレッドを中断する必要がある場合は、ThreadGroup割り込みメソッドを使用すれば、すべてのスレッドが中断されます。

public class GroupThreadFactory implements ThreadFactory { 
    private ThreadGroup group; 

    public GroupThreadFactory(ThreadGroup group) { 
     this.group = group; 
    } 

    public Thread newThread(Runnable r) { 
     return new Thread(group, r); 
    } 
}