Java等待线程(Threadpool)完成工作并开始另一项工作

use*_*927 4 java multithreading

所以我创建了5个线程,在完成工作后我想做另一个工作.那么如何找出执行者的线程何时完成他们的工作,然后才开始超级工作方法呢?

主要:

 ExecutorService executor = Executors.newFixedThreadPool(5);
   CountDownLatch doneSignal = new CountDownLatch(5);//thread number
   for(int i=0;i<5;i++){

   getLogFile n = new getLogFile(doneSignal, i);// work method

   executor.execute(n);
   doneSignal.await();  
   }
Run Code Online (Sandbox Code Playgroud)

//可能这里有类似executor.awaitTermination(60,TimeUnit.SECONDS); {不起作用}或者有效的东西

Superworkmethod(uses thread created files);//main thread probably starts thi
Run Code Online (Sandbox Code Playgroud)

类:

public static class getLogFile implements Runnable {
 private final CountDownLatch doneSignal;
   private final int i;
   getLogFile(CountDownLatch doneSignal, int i) {
      this.doneSignal = doneSignal;
      this.i = i;
   }

    public int run1(String Filenamet) {
    //do work
    }
    public void run() {
            run1(file);
            doneSignal.countDown();
    }
Run Code Online (Sandbox Code Playgroud)

}

axt*_*avt 6

你可以使用ExecutorService.invokeAll():

ExecutorService executor = Executors.newFixedThreadPool(5);

List<Callable<Object>> tasks = new ArrayList<Callable<Object>>();    
for(int i=0;i<5;i++){
    tasks.add(Executors.callable(new getLogFile(doneSignal, i)));
}

executor.invokeAll(tasks);
// Here tasks are completed
Run Code Online (Sandbox Code Playgroud)