スレッドコンテキストを取得するjava

Question

おそらくそれは簡単ですが、どのようにすればよいか分かりません。

最初に、エグゼキュータでクラスB（ランナブル）を1つ以上作成するクラスAを持っています。 各クラスBはいくつかのタスクを実行する必要がありますが、各スレッドが終了した時点を知りたいと思います。

Class A { 
    private ScheduledExecutorService scheduler; 
    private int nbThread=3; 
    public A(){ 
     scheduler = Executors.newScheduledThreadPool(nbThread); 
    } 

    public start(){ 
     for (int i = 0; i < nbThread; i++) { 
      scheduler.execute(new B(); 
     } 
    } 

}

Class B implement Runnable { 

    public B(){ 

    } 

    @Override 
    public void run(){ 
     System.out.printl("test"); 
    } 

}

今、私が欲しいもの、それらの3つのスレッドがそれぞれ1（System.out.printlnは（ "テスト"） もし印刷する場合にのみ、他のタスクを実行することです 私はJavaであまり強くないので、いくつかの助けが必要です。 ありがとう

Answer 1

あなたは何をしたいですか？で見るにはFuture Javaの同時パッケージのインターフェイスです。

startメソッドを更新して、使用方法の例を示しました。

public void start() { 
    Future<?>[] futures = new Future[nbThread]; 

    for (int i = 0; i < nbThread; i++) { 
     futures[i] = scheduler.submit(new B()); 
    } 

    for (int i = 0; i < nbThread; i++) { 
     try { 
      futures[i].get(); // waits until the current B is done, and then just returns null 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    // All futures now finished executing 
} 

---

更新：代替ソリューションあなたは、常にすべてのタスクが完了するまで待機する場合はExecutorService.invokeAllを使用することです。次の例のように（私はCallableを実装するためにBを変更することに注意してください。

class A { 
    private ScheduledExecutorService scheduler; 
    private int nbThread = 3; 

    public A() { 
     scheduler = Executors.newScheduledThreadPool(nbThread); 
    } 

    public void start() { 
     List<Callable<Object>> callables = new ArrayList<>(); 
     callables.add(new B()); 
     callables.add(new B()); 
     callables.add(new B()); 
     try { 
      scheduler.invokeAll(callables); // blocks until all B finished executing 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 

     // All B's now finished executing 

    } 
} 

class B implements Callable<Object> { 

    public B() { 

    } 

    @Override 
    public Object call() throws Exception { 
     System.out.println("test"); 
     return null; 
    } 
}