Java의 다중 스레드 동기화를 위한 CountDownLatch의 예제 코드 공유

이 글에서는 주로 멀티 스레드 동기화를 위한 Java의 CountDownLatch에 대한 자세한 설명과 예제 코드를 소개합니다. 도움이 필요한 친구들은

Java의 CountDownLatch에 의한 멀티 스레드 동기화에 대한 자세한 설명

CountDownLatch 소개

이전 Java 연구 노트에는 Java의 다중 스레드 동기화를 위한 여러 가지 방법이 요약되어 있습니다.

1. 동기화를 위한

동기화 키워드입니다. 2. 잠금 잠금
인터페이스 및 해당 구현 클래스 ReentrantLock 및 ReadWriteLock 잠금은 동기화를 달성합니다. 3. 세마포어는 동기화를 구현합니다.

그 중 동기화 키워드와 Lock 잠금은 여러 스레드가 동일한 리소스에 동시 접근하는 문제를 해결합니다. 세마포어는 여러 리소스 복사본에 대한 공유 액세스 문제를 해결합니다.

오늘은 Java의 또 다른 멀티 스레드 동기화 보조 클래스인 CountDownLatch에 대해 알아 보겠습니다. 공식 문서에서는 CountDownLatch를 다음과 같이 설명합니다. 이를 통해 하나 이상의 스레드가 다른 스레드에서 수행되는 일련의 작업이 완료될 때까지 대기할 수 있습니다. 즉, CountDownLatch는 하나 이상의 스레드를 제어하고 시작하기 전에 여러 스레드가 특정 작업을 완료할 때까지 기다릴 수 있도록 합니다. CountDownLatch는 주로 여러 작업의 실행을 동기화하는 데 사용되며, 공유 리소스를 동기화하는 데 사용되는 다른 동기화 키워드, 잠금 및 세마포어와 다릅니다.

CountDownLatch 구현 원칙 소개:

CountDownLatch는 내부적으로 카운터 값을 유지합니다. N이 완료되고 이 N을 기다려야 합니다. 작업을 완료한 스레드는

CountDownLatch의 wait() 메서드를 호출하여 자신을 휴면 대기 상태로 전환합니다.

작업 스레드는 작업이 완료되면 CountDownLatch의 countDown() 메서드를 호출하여 해당 작업이 완료되었음을 나타냅니다. 이때 CountDownLatch의 카운터 값이 1만큼 감소합니다. 모든 작업이 완료되었습니다. 카운터 값은 0입니다. 카운터 값이 0이면 CountDownLatch는 wait() 메서드로 인해 절전 모드에 들어간 모든 스레드를 깨웁니다.

CountDownLatch 사용법:

CountDownLatch를 사용하는 데에는 세 가지 주요 사항이 있습니다.

1. CountDownLatch 그리고 초기화 중에는 초기화 중에 완료되기를 기다리는 작업 수를 지정해야 합니다.

2. 특정 작업이 완료되면 CountDownLatch의 countDown() 메서드를 호출하여 해당 작업이 완료되었음을 CountDownLatch에 보고합니다.

3. 모든 작업이 완료된 후 CountDownLatch의 카운터 값이 0이 되면 스레드는 대기 상태가 됩니다. wait() 메서드가 깨어납니다.

여기에서는 CountDownLatch의 사용법 세부 사항을 보여주기 위해 Java 7 동시 프로그래밍 실용 매뉴얼의 CountDownLatch 사용법 예제를 기반으로 몇 가지 개선 사항을 적용했습니다.

회의를 시뮬레이션합니다. 참가자 10명 및 중재자 각 참가자와 중재자는 다른 참가자가 로그인할 때까지 기다려야 회의를 시작하고 발언할 수 있습니다. 이를 수행하려면 먼저 관리할 VideoConference 클래스를 생성합니다. 이 클래스는 참가자가 체크인을 위해 호출할 수 있는 Arrival() 메서드를 제공합니다. 컨퍼런스 관리의 소유자는 각 참가자가 로그인할 때까지 기다리는 호스트입니다:

public class VideoConference implements Runnable{ 
  private final CountDownLatch countDownLatch; 
  private int number; 
  public VideoConference(int number) { 
    this.number = number; 
    this.countDownLatch = new CountDownLatch(number);//使用Number初始化其内部的计数器，当初始化完成后，不能再次初始化 
  } 
  public void arrive(String name){ 
    //每个需要同步的任务，在任务完成时，需要调用该方法 
    countDownLatch.countDown();//countDownLatch内部的计数器减1 
    System.out.print("arrive:"+name+"\n"); 
    try{ 
      countDownLatch.await();//await方法是线程进入休眠，当countDownLatch计数器为0时，将被唤醒 
      //线程被唤醒，在这里可以执行一系列任务 
      System.out.print("name:"+name + " say:let's start..." +"\n"); 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    } 
  } 
  public void run(){ 
    System.out.print("has arrive:"+(number-countDownLatch.getCount())+"\n"); 
    try{ 
      countDownLatch.await();//await方法是线程进入休眠，当countDownLatch计数器为0时，将被唤醒 
      //线程被唤醒，在这里可以执行一系列任务 
      System.out.print("all arrived:"+(number-countDownLatch.getCount())+"\n"); 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    } 
  } 
}

참가자 클래스 만들기 참가자:

public class Participant implements Runnable{ 
  private VideoConference videoConference; 
  private String name; 
 
  public Participant(String name, VideoConference videoConference) { 
    this.name = name; 
    this.videoConference = videoConference; 
  } 
  public void run(){ 
    try { 
      //do something 
      Thread.sleep(50); 
      // 
      videoConference.arrive(name); 
    }catch (InterruptedException e){ 
      e.printStackTrace(); 
    } 
  } 
 
  public static void main(String[] args){ 
    VideoConference videoConference = new VideoConference(10); 
    Thread videoThread = new Thread(videoConference); 
    videoThread.start(); 
    for(int i=0; i<10; i++){ 
      Thread thread = new Thread(new Participant("participant:"+i,videoConference)); 
      thread.start(); 
    } 
  } 
}

main

참가자 클래스의 기능 먼저 10명의 참가자가 필요한 회의를 생성한 다음 10명의 참가자를 생성하고 한 명씩 로그인합니다. 10명의 참가자가 모두 로그인하면 각 참가자와 호스트가 "깨어나고" 발언합니다.

요약:

CountDownLatch 클래스는 여러 스레드 간의 동기화 대기 및 작업 조정 문제를 해결합니다. 프로그램을 시작할 때 사용할 수 있습니다. . 주요 기능 이전에 구성 환경 확인, 네트워크 확인 등과 같은 여러 하위 작업 및 유사한 시나리오를 미리 완료해야 합니다. Java에서는 CountDownLatch를 사용하여 다중 스레드 간의 동기 대기를 달성하는 것 외에도 CyclicBarrier 장벽 기술을 사용하여 다중 스레드 간의 동기 대기 및 작업 조정을 달성할 수도 있습니다.

위 내용은 Java의 다중 스레드 동기화를 위한 CountDownLatch의 예제 코드 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!