[java] CountDownLatch는 Java 멀티 스레딩에서 어떻게 사용됩니까?

하나 이상의 스레드가 작업을 완료하기를 기다릴 때 사용됩니다. 스레드에서 조인하는 것과 비슷합니다.

CountDownLatch를 사용할 수있는 곳

세 개의 스레드 “A”, “B”및 “C”가 있고 “A”및 “B”스레드가 작업을 완료하거나 부분적으로 완료 할 때만 스레드 “C”를 시작하려는 시나리오가 있다고 가정합니다.

실제 IT 시나리오에 적용 가능

관리자가 개발 팀 (A와 B)간에 모듈을 나누고 두 팀이 작업을 완료 한 경우에만 테스트를 위해 QA 팀에 모듈을 할당하려는 시나리오를 고려하십시오.

public class Manager {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(2);
        MyDevTeam teamDevA = new MyDevTeam(countDownLatch, "devA");
        MyDevTeam teamDevB = new MyDevTeam(countDownLatch, "devB");
        teamDevA.start();
        teamDevB.start();
        countDownLatch.await();
        MyQATeam qa = new MyQATeam();
        qa.start();
    }
}

class MyDevTeam extends Thread {
    CountDownLatch countDownLatch;
    public MyDevTeam (CountDownLatch countDownLatch, String name) {
        super(name);
        this.countDownLatch = countDownLatch;
    }
    @Override
    public void run() {
        System.out.println("Task assigned to development team " + Thread.currentThread().getName());
        try {
                Thread.sleep(2000);
        } catch (InterruptedException ex) {
                ex.printStackTrace();
        }
    System.out.println("Task finished by development team Thread.currentThread().getName());
            this.countDownLatch.countDown();
    }
}

class MyQATeam extends Thread {
    @Override
    public void run() {
        System.out.println("Task assigned to QA team");
        try {
                Thread.sleep(2000);
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        }
        System.out.println("Task finished by QA team");
    }
}

위 코드의 출력은 다음과 같습니다.

개발 팀 devB에 할당 된 작업

개발 팀 devA에 할당 된 작업

개발 팀 devB에 의해 완료된 작업

개발 팀 devA에 의해 완료된 작업

품질 보증팀에 할당 된 작업

품질 관리팀에서 작업 완료

여기서 await () 메소드는 countdownlatch 플래그가 0이 될 때까지 대기하고 countDown () 메소드는 countdownlatch 플래그를 1 씩 감소시킵니다.

JOIN의 제한 :
위의 예는 JOIN으로 도 달성 할 수 있지만 JOIN은 두 가지 시나리오에서 사용할 수 없습니다.

1. Thread 클래스 대신 ExecutorService를 사용하여 스레드를 만드는 경우
2. 개발이 80 % 작업을 완료하자마자 Manager가 QA 팀에게 코드를 전달하려는 위의 예를 수정하십시오. CountDownLatch를 사용하면 부분 실행을 위해 다른 스레드를 기다리는 데 사용할 수있는 구현을 수정할 수 있습니다.

답변

// Main thread starts
// Create CountDownLatch for N threads
// Create and start N threads
// Main thread waits on latch
// N threads completes there tasks are returns
// Main thread resume execution

CountDownLatch latch;
void writeData() {
   latch = new CountDownLatch(1);
   serialPort.writeBytes(sb.toString().getBytes())
   try {
      latch.await(4, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
   }
}
class SerialPortReader implements SerialPortEventListener {
    public void serialEvent(SerialPortEvent event) {
        if(event.isRXCHAR()){//If data is available
            byte buffer[] = serialPort.readBytes(event.getEventValue());
            latch.countDown();
         }
     }
}

latch.countDown();
System.out.println("DONE "+this.latch); // Add this debug

DONE java.util.concurrent.CountDownLatch@70e69696[Count = 2]
DONE java.util.concurrent.CountDownLatch@70e69696[Count = 1]
DONE java.util.concurrent.CountDownLatch@70e69696[Count = 0]