java等待池中的所有线程

Question

当按下暂停按钮并重新运行播放按钮时，是否有办法等待执行程序池中的所有线程？我试过CountDownLatch，但我不知道我必须把它放在executor声明或run（）方法之后？我没有关于threads.please多的信息可有人告诉我，我怎么能do.Thanks

public static CountDownLatch waiter; 
public static ExecutorService pool; 

public Action() throws InterruptedException{ 
    pool=Executors.newFixedThreadPool(2); 
    waiter=new CountDownLatch(2); // to wait 
    robot1=new Robot(0,560,"rbt1"); // starts random free position 
    robot2=new Robot(0,560,"rbt2"); 
    if(Frame.pause==false){ 
     pool.submit(robot1); 
     pool.submit(robot2);} 
    if(Frame.pause==true){ 
     waiter.await(); 
    } 


} 

Answer 1

您的机器人工作人员需要共享的线程安全方式来检查工作人员是否应该暂停或正在玩耍。在工作者的run（）方法中，如果线程已暂停，请等待此锁定对象的通知。在循环或工作人员所做的任何事情的同时，定期检查锁的状态，并在需要时暂停工作人员。

pauseIfNeeded() { 
    synchronized(workerLock) { 
     if (workerLock.isPaused()) { 
      workerLock.wait(); 
     } 
    } 
} 

你的暂停和播放按钮应该得到的workerLock同步锁定，并设置暂停属性，调用notify（）的workerLock。这将让工人暂停或继续按需。无论暂停/播放状态如何，执行程序总是“正在运行”。

编辑 您可以重构上面的代码变成自己的类，如下所示：

public class WorkerPauseManager { 

    private boolean paused; 

    public synchronized void pauseIfNeeded() throws InterruptedException { 
     if (paused) wait(); 
    } 

    public synchronized void pause() { 
     this.paused = true; 
    } 

    public synchronized void start() { 
     this.paused = false; 
     notifyAll(); 
    } 
} 

创建WorkerPauseManager的单个实例。将此实例传递给所有机器人工作人员，并为摆动暂停/播放操作提供参考。你的工作线程应该调用pauseIfNeeded。

下面是一个使用WorkerPauseManager的SCCE：

public class WorkerPauseManagerTest { 
    public static void main(String[] args) { 
     final WorkerPauseManager pauseManager = new WorkerPauseManager(); 
     new Worker("Worker 1", pauseManager).start(); 
     new Worker("Worker 2", pauseManager).start(); 
     SwingUtilities.invokeLater(new Runnable() { 
      public void run() { 
       JToggleButton playPauseButton = new JToggleButton(new AbstractAction("Pause") { 
        public void actionPerformed(final ActionEvent e) { 
         JToggleButton source = (JToggleButton) e.getSource(); 
         if (source.isSelected()) { 
          pauseManager.start(); 
          source.setText("Pause"); 
         } else { 
          pauseManager.pause(); 
          source.setText("Play"); 
         } 
        } 
       }); 
       JOptionPane.showMessageDialog(null, playPauseButton, "WorkerPauseManager Demo", JOptionPane.PLAIN_MESSAGE); 
       System.exit(0); 
      } 
     }); 

    } 

    private static class Worker extends Thread { 
     final String name; 
     final WorkerPauseManager pauseManager; 

     public Worker(final String name, final WorkerPauseManager pauseManager) { 
      this.name = name; 
      this.pauseManager = pauseManager; 
     } 

     @Override 
     public void run() { 
      while (!Thread.interrupted()) { 
       try { 
        pauseManager.pauseIfNeeded(); 
        System.out.println(name + " is running"); 
        Thread.sleep(1000L); 
       } catch (InterruptedException e) { 
        throw new RuntimeException(e); 
       } 
      } 
     } 
    } 
} 

Answer 2

可以等待所有的线程与完成：

pool.awaitTermination(60, TimeUnit.SECONDS); // hopefully 60 seconds are enough 

参见：http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/ExecutorService.html#awaitTermination%28long,%20java.util.concurrent.TimeUnit%29