为什么我的第二个线程没有运行？

Question

我有以下程序，我希望有3个线程的吸烟者等待代理。我正在尝试使用CountDown锁存器来实现这一点。

public void runThreads(){ 
      int numofTests; 
      Scanner in = new Scanner(System.in); 
      System.out.print("Enter the number of iterations to be completed:"); 
      numofTests = Integer.parseInt(in.nextLine());///Gets the number of tests from the user 
      Agent agent = new Agent(); 
      Smoker Pam = new Smoker ("paper", "Pam"); 
      Smoker Tom = new Smoker ("tobacco", "Tom"); 
      Smoker Matt = new Smoker ("matches", "Matt"); 

      for(int i = 0; i < numofTests; i++){ //passes out as many rounds as the user specifies 
       Pam.run(); 
       Tom.run(); 
       Matt.run(); 
       agent.run(); 
      } 

对于当我运行Pam.run用下面的代码，它只是冻结在latch.await某种原因，我的线程不运行的其余部分。所以我的问题是我如何正确地做到这一点，以便前3名吸烟者等待latch.countdown（）;由代理线程调用。

public class Smoker implements Runnable{ 
     String ingredient; //This is the one ingredient the smoker starts out with 
     String name; 
     public static CountDownLatch latch = new CountDownLatch(1); 
     int numOfSmokes = 0; //Total number of cigs smoker smoked; 

     public Smoker(String ingredient1, String Name) 
     { 
      ingredient1 = ingredient; 
      name = Name; 
     } 

     public void run(){ 
      try { 
       System.out.println(this.name + " waits on the table..."); 
       latch.await();///waits for agent to signal that new ingredients have been passed out 
      } catch(InterruptedException ex) { 
       Thread.currentThread().interrupt(); 
      } 
      System.out.println(this.name + " stops waiting and checks the table..."); 
      checkTable(); 
     } 

Answer 1

您应该创建一个Thread并通过Runnable实例作为参数。此外，您应该拨打start功能，而不是run。更改您的代码

(new Thread(Pam)).start(); 
//similar for others... 

信息：Defining and Starting a Thread