スレッドを終了するスレッドを待つ

Question

StopWatch sw = new StopWatch(); 
    sw.start(); 
    ExecutorService executor = Executors.newFixedThreadPool(MYTHREADS); 

    for (int i = 0; i < MYTHREADS; i++) { 
     Runnable worker = new SingleConnectionRunnable(); 
     executor.execute(worker); 
    } 

    sw.stop(); 
    System.out.println("total time"+sw.toString()); 
    sw.reset(); 
    sw.start(); 

    for (int i = 0; i < MYTHREADS; i++) { 
     Runnable worker2 = new PooledConnectionRunnable(); 
     executor.execute(worker2); 
    } 
    executor.shutdown(); 
    executor.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS); 
    while (!executor.isTerminated()) { 

    } 

    sw.stop(); 
    System.out.println("total time"+sw.toString()); 

上記のコードでいくつかのperfテストを実行しようとしています。私は別のRunnableに同じexecutorを使用して時間を測定しようとしています。しかし、それはまったく機能しません。最初の「合計時間」は正しくありません。これはミリ秒単位です。

最初のループで経過時間を印刷してから、2番目のループを印刷します。エグゼキュータを最初に終了してからエグゼキュータを再起動する方法を確認できない

これを行う正しい方法は何ですか？

Answer 1

まず、すべてのタスクが終了するまでawaitTerminationはblockになります。潜在的に70 yearsを待ってからwhileループチェックを使用する特別な理由はありますか？

質問に答えるには、最初の実行が完了するのを待つために、CountDownLatchを使用して各スレッドの完了を通知し、完了するまでメインスレッドで待機してください。また、すべてのあなたのスレッドがそうのように、タイミングを開始する前に行く準備が整うまで待つCyclicBarrierを使用することができます。

... 
CountDownLatch latch = new CountDownLatch(MYTHREADS); 
CyclicBarrier cb = new CyclicBarrier(MYTHREADS, new Runnable() { 
    @Override public void run() { 
     sw.start(); 
    } 
}); 

for (...) { 
    Runnable worker = ... 
    executor.execute(new Runnable() { 
     @Override public void run() { 
      try { 
       cb.await(); 
      } catch (Exception e) { 
       throw new RuntimeException(e); 
      } 

      worker.run(); 
      latch.countDown(); 
     } 
    }); 
} 

latch.await(); 
sw.stop(); 
... 

私はセットアップにオブジェクト割り当てのオーバーヘッドを測定避けるために、forループの先頭にsw.start()を移動しました（おそらく、それはミリ秒単位で測定されないでしょう）。

また、2つの並行性クラスを無期限に実行するようにリセットすることもできます。

Answer 2

何が今やっていることは次のとおりです。

1. が
2. あなたがのように仕上げるためにあなたが彼らを待っていないストップウォッチ

を読むストップウオッチ

スタートを数のスレッドを起動します2番目のループで

---

これはこれを解決するための方法です。

SingleConnectionRunnableでコールバックメソッドを作成します。

このメソッドは、この実行時の最後の時点（終了時）に呼び出され、ループを開始するクラスによってキャッチされます（これは問題のメソッドではありませんが問題ありません）。

このコールバックメソッドでは、呼び出された回数を追跡します。

MYTHREADと呼ばれるときは、ストップウォッチの時間を印刷します。

開始されたスレッドがすべて終了するまでにどれくらいかかります。