Java의 CountDownLatch를 스레드가 아닌 수동 클래스에서 사용할 수 있습니까?

Question

그래서 저는 직장에서 하루를 시뮬레이션하는이 프로그램을 작업하고 있으며 각 작업자는 자체 스레드입니다. 나는 근로자가 회의에 참석하지만 회의에 참석해야하는 모든 사람이 도착할 때까지 회의가 시작되지 않는 회의를 구현하려고합니다. 그래서 회의에 참석하는 방법이 있습니다.

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 

worker 매개 변수는 Thread를 확장하는 Employee 클래스의 인스턴스이고 this.cdStart는 CountDownLatch입니다. 그러나 4 명의 직원과의 회의에서이 작업을 실행하면 단 한 명의 직원 만 들어 와서 카운트를 줄이고 await() 호출을 수행 할 수 있습니다. 다른 작업자 스레드 중 아무 것도 입력 할 수없는 것 같습니다. 나는 많은 온라인 예제를 사용하여 CountDownLock 객체를 스레드 자체에 전달하여 처리 할 수 ​​있음을 확인했습니다. 이것이 대신 작동하지 않는 이유가 있습니까?

Answer 1

Employee Thread 개체에 단일 스레드 패스가 있다고 가정합니다. 이 단일 스레드는 N 개의 참여자가 도착할 때까지 무기한 대기합니다 (Employee 스레드 이외의 각 Employee 인스턴스에 대해 개별 스레드가 필요함). 즉, 하나의 스레드 만 지속적으로 Employee/Thread를 통과하면 더 이상 한 명의 직원이 회의에서 대기하지 않습니다.

대신이 스레드는 회의에 참석하기 위해 직원 스레드에 신호해야합니다.

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(); 
    } 
    } 

그러나 나는 이것이 CylicBarrier라고 제안합니다. 당신이 그것을 사용하여 다시되지 않을 있지만,으로 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 
    } 
}