java 병렬 프로 그래 밍 테마(6)---분석(JUC)Semaphore

중간 에 보신 분 들 은 전편 을 되 돌아 볼 수 있어 요.
자바 병렬 프로 그래 밍 테마(1)-스 레 드 기초 지식
자바 병렬 프로 그래 밍 테마(2)-자바 스 레 드 를 만 들 고 실행 하 는 방법
자바 병렬 프로 그래 밍 테마(3)-상세 한 스 레 드 동기 화
자바 동시 프로 그래 밍 테마(4)---간단 한 이야기(JUC)잠 금 자물쇠
java 병렬 프로 그래 밍 테마(5)---상세(JUC)ReentrantLock
Semaphore,말 그대로 우 리 는 그 가 신 호 량 이라는 뜻 을 안다.자바 에 서 는 하나의 계수 신 호 량 이 허가 집합 을 유지 하고 있 습 니 다.Semaphore 는 허 가 된 번호 만 계산 하고 해당 하 는 행동 을 취한 다.신 호 량 을 받 은 스 레 드 는 코드 에 들 어 갈 수 있 습 니 다.그렇지 않 으 면 기다 릴 수 있 습 니 다.acquire()와 release()를 통 해 방문 허 가 를 받 고 방출 합 니 다.
신 호 량 Semaphore 는 여러 개의 공유 자원 에 접근 하 는 것 을 제어 하 는 계수기 로 본질 적 으로'공유 자물쇠'이다.
자바 병발 은 두 가지 잠 금 모드 를 제공 합 니 다.공유 잠 금 과 독점 잠 금 입 니 다.앞서 소 개 된 ReentrantLock 이 독점 자물쇠 다.독점 자물쇠 의 경우 매번 하나의 스 레 드 만 가지 고 있 을 수 있 고 공유 자 물 쇠 는 다 르 기 때문에 여러 스 레 드 가 동시에 자 물 쇠 를 가지 고 공유 자원 에 접근 할 수 있 습 니 다.
독점 자 물 쇠 는 비관 적 인 잠 금 전략 을 사용 하 는데 쓰기 에 있어 서 충돌 독점 을 피하 기 위해 서 는 필수 적 이지 만 읽 기 에 필요 하지 않 습 니 다.데이터 의 일치 성에 영향 을 주지 않 기 때 문 입 니 다.만약 에 읽 기 전용 스 레 드 가 독점 자 물 쇠 를 가 져 오 면 다른 읽 기 스 레 드 는 기다 릴 수 밖 에 없다.이런 상황 에서 불필요 한 동시성 을 제한 하고 스루풋 을 낮 출 수 있다.한편,공유 자 물 쇠 는 서로 다 르 기 때문에 자 물 쇠 를 추가 하 는 조건 을 완화 하고 낙관적 인 잠 금 체 제 를 사용 하여 여러 개의 읽 기 스 레 드 가 같은 공유 자원 에 동시에 접근 할 수 있 도록 한다.
생활 속 의 예 를 들 어 일방 통행 로 길목 에 신호등 이 있 는데 정상 적 인 신호등 시간 에 자전 거 를 타 는 속도 가 평균 20 대 밖 에 지나 지 않 는 다 면 앞 에 있 는 20 대 는 신호등 을 지나 갈 수 있 고 뒤에 있 는 것 은 다음 신호등 을 기다 릴 수 밖 에 없다 는 것 을 의미한다.하지만 이때 이 길목 을 지나 가 고 싶 지 않 은 차 가 다른 길 로 향 했다 면 뒤의 차 는 기회 가 있 었 을 것 이다.다음은 간단 한 예 를 살 펴 보 자.

public class TestSemaphore {
 public static void main(String[] args) {
  final Semaphore semaphore = new Semaphore(5);
  ExecutorService executorService = Executors.newCachedThreadPool();
  for(int i = 0;i<10;i++){
   int j = 0;
   executorService.submit(new A("car"+(j++),semaphore),"Thread"+(j++));
   //new Thread(new A("car"+(j++),semaphore),"Thread"+(j++)).start();
   if(i == 5){
    try {
     Thread.sleep(1000);
     System.out.println("    "+semaphore.availablePermits()+"     ");
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
   }
  }

  System.out.println("    "+semaphore.availablePermits()+"     ");
 }

 }
 class A implements Runnable{
  String carName;
  private Semaphore semaphore;

  public A(String carName, Semaphore semaphore){
   this.carName = carName;
   this.semaphore = semaphore;
  }

  public void getWay(){
   System.out.println("this car is get the way" + Thread.currentThread().getName());
  }

  public void run() {
   try {
    if(semaphore.availablePermits() > 0){
     semaphore.acquire();
     getWay();
     semaphore.release();
    }else{
     System.out.println("   ========");
    }
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
 }
이상 은 자바 병행 프로 그래 밍 주제(6)-분석(JUC)Semaphore 의 상세 한 내용 입 니 다.JAVA Semaphore 에 관 한 자 료 는 저희 의 다른 관련 글 을 주목 해 주 십시오!

좋은 웹페이지 즐겨찾기