Javaは：フォースExecutorServiceのスレッドの停止

Question

マイコード：

String[] torrentFiles = new File("/root/torrents/").list(); 

     if(torrentFiles.length == 0 || torrentFiles == null) 
     { 
      System.exit(0); 
     } 

     ex = Executors.newFixedThreadPool(3); 

     for(String torrentFile : torrentFiles) 
     { 
      ex.submit(new DownloadTorrent("/root/torrents/" + torrentFile)); 
     } 

     ex.shutdown(); 

     try 
     { 
      ex.awaitTermination(30, TimeUnit.MINUTES); 
     } 
     catch(InterruptedException ex1) 
     { 
      Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex1); 
     } 

しかし、時には急流のダウンロードは未知の時間値を取り、«awaitTermination»私が望むように動作しません。私はすべての実行スレッドを30分後に即座に停止する必要がありますが、私が知っているように«awaitTermination»ちょうどinterrupt()ループまたは待機中の方法を使用してください。だからこの瞬間が起これば、タイムアウトはうまくいかない。だから、どのように？

Answer 1

ExecutorService.shutdownNow()はここ

...すべての実行中のスレッドを停止しようとしたjavadocからの引用のすべての積極的 実行中のタスクを停止する

List<Runnable> shutdownNow()

試みは、の処理 を停止しています の実行を待機していたタスクのリスト を返します。

ベストエフォート型の試みを超えて、アクティブに実行されているタスクを処理しようとする試みを超えた保証はありません。 たとえば、一般的な実装 はThread.interrupt（）を介してキャンセルされるため、 タスクがマスクするか、または が割り込みに応答しないと、 が終了しないことがあります。

Answer 2

ExecutorService.submit(...)cancel()メソッドを持つFuture<?>を返します。それぞれのタスクを停止させたいときは、これらのタスクを呼び出すことができます。

Answer 3

スレッドがisInterrupted（）フラグを定期的にチェックしていないか、割り込み可能なメソッドで待機している、つまりInterruptedExceptionをスローしていない限り、インスタントスレッド終了は保証されません。

isInterrupted（）を定期的にチェックするときにワーカースレッドを実装することを検討してください。おそらく急流のダウンロードはIO操作をブロック伴うので、それぞれのスレッドが中断されたときに、ブロッキングIO操作が終了することが保証されていないので、単にcancel()/shutdownNow()を呼び出すと、十分ではないでしょう

public void run() { 
    byte[] data; 
    do { 
    data = receiveDataChunk(timeout); 
    processData(data); 
    } while(!isInterrupted() && data != null); 
} 

Answer 4

：これはそのような何かかもしれ。

IOのブロックをキャンセルするには、基になるソケットを閉じる必要があります。How to terminate a thread blocking on socket IO operation instantly?を参照してください。

Answer 5

今はプールからスレッドを停止する必要があります。私はそんなやり方をしている。それは良い考えではないかもしれません。もしそうなら、コメントしてください。

boolean isTerminated = mPoolThreads.isTerminated(); 
while (!isTerminated) { 
    mPoolThreads.shutdownNow(); 
    isTerminated = mPoolThreads.isTerminated(); 
    Log.i(Constants.LOG_TAG, "Stop threads: the threads are not terminated yet"); 
} 
Log.w(Constants.LOG_TAG, "Stop threads: Terminated"); 

Answer 6

amこのコードを使用して作成しました。

wkhtmltopdfを使用して、多くのhtmlテンプレートから多数のpdfファイルを生成しています。

私はクライアントを待たずにハンドレッドを作成するパフォーマンスを向上させたいと考えていますが、これは実装の一部に過ぎません。

約getListOfCallables固定プールの作成で使用するスレッドの数に応じて、最適な のしきい値が戻されます。

私はそれを囲んでいるデッドスレッドをたくさん持っていることを扱うことができないので、私のEC2 CPUが100％スタックした。

私が使用：

• シャットダウン（）
• shutdownNowのを（）
• shutdownNowの（）例外一部で

一覧fileGenerationHtmlToPdfList = getListOfCallables（パス、名前、待つの他にオプション）;

  ExecutorService executorService = Executors.newFixedThreadPool(fileGenerationHtmlToPdfList.size()); 


      List<Future<ArrayList<File>>> futures = null; 

      try { 
       futures = executorService.invokeAll(fileGenerationHtmlToPdfList); 
       try { 
        for(Future f: futures) { 
         files.addAll((ArrayList<File>)f.get()); 
        } 

       } catch (InterruptedException ex) { 
        Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex); 
       } catch (ExecutionException ex) { 
        Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex); 
       } 
      } catch (InterruptedException ex) { 
       Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex); 
      } 

executorService.shutdown();//try shutdown 

      try { 
       if (executorService.awaitTermination(5, TimeUnit.SECONDS)) { 
        Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Done ShutDowned"); 
       } else { 
        executorService.shutdownNow(); 
       } 
      } catch (InterruptedException ex) { 
       executorService.shutdownNow(); 
       Logger.getLogger(FileUtil.class.getName()).log(Level.SEVERE, "Interrupted Exception " , ex); 
      }