JavaのCountDownLatchをスレッドではなくパッシブクラスから使用できますか？

Question

私は仕事で1日をシミュレートするこのプログラムに取り組んでおり、各作業者はそれぞれのスレッドです。私は、労働者が会議に出席する会議を実施しようとしていますが、会議に参加するはずの人が到着するまで会議は開始しません。だから、私はこの会議に出席する方法を持っています。

public void attendMeeting(Employee worker){ 
    this.cdStart.countDown(); 
    worker.meetingWait(); 
    try { 
     this.cdStart.await(); 
     worker.meetingStart(this.length); 
     if(this.attendees.get(0).equals(worker)){ 
      this.room.exit(); 
     } // end if 

    } // end try 
    catch (InterruptedException err) { 
     // Do Nothing 

    } // end catch 

} // end method attendMeeting 

スレッドを拡張しthis.cdStartがたCountDownLatchあるEmployeeクラスのインスタンスであるワーカー・パラメータ。しかし、これを4人の従業員の会議で実行すると、1人の従業員だけが入り込んでカウントを減らし、await（）コールを打つことができます。他のワーカースレッドのどれもそれに入ることができないようです。私は、多くのオンライン使用例がCountDownLockオブジェクトをスレッド自体に渡して処理することに気付きました。これが代わりに機能しない理由はありますか？

Answer 1

私はあなたがEmployee Threadオブジェクトに1つのスレッドを渡していると仮定しています。 N個の当事者が到着するまで、その単一のスレッドは無期限に待機します（Employeeスレッド以外の各Employeeインスタンスに対して個別のスレッドが必要です）。これは、1つのスレッドだけが従業員/スレッドを継続的に通過している場合、会議で待っている従業員が2人以上になることはありません。

このスレッドは、せいぜい会議に出席するために従業員スレッドに通知する必要があります。

ラッチをMeetingクラスに配置し、そのラッチを待つ必要があります。これはまた、それが動作する方法のわずかな再構成を必要とします。

MeetingインスタンスをEmployeeに渡して、そのスレッドを待機させます。

public Employee extends Thread{ 

    //define this at some point whether in constructor or a 
    //means of notifying the thread to attend the meeting 
     private Meeting meeting; 

     public void run(){ 
      //do some stuff until this employee is ready to go to a meeting 

     meeting.waitForAllOthersToArrive(); 
     } 

    } 

    public class Meeting{ 
    CountDownLatch latch = new CountDownLatch(numberOfEmployees); 

    public void waitForAllOthersToArrive(){ 
     latch.countDown(); 
     latch.await(); 
    } 
    } 

私がこれについて示唆しているのは、シリルバリアです。あなたがそれを使用して再されないものの、CyclicBarrierをが動作する方法は、あなたが何をしようとして、より良いフィットし、会議のクラスは、worker.meetingWait（）は何をするん

public class Meeting{ 
    CylicBarrier barrier = new CylicBarrier(numberOfEmployees); 

    public void waitForAllOthersToArrive(){ 
     barrier.await(); //when await() is called numberOfEmployees then all waiting threads will awake 
    } 
}