자바 병렬 시리즈 CountDownlatch 소스 분석
6731 단어 Java동시 다발 시리즈CountDownLatch
위의 그림 은 5 개의 스 레 드 가 await 방법 을 호출 하여 막 혔 음 을 보 여 줍 니 다.카운터 의 값 이 0 으로 줄 어 들 기 를 기 다 려 야 계속 실 행 될 수 있 습 니 다.계수기 의 초기 값 은 구조 가 잠 겨 있 을 때 지정 되 며,그 다음 에는 매번 countDown 방법 이 호출 될 때마다 1 이 줄어든다.아래 코드 는 Count Downlatch 의 구조 방법 을 붙 였 습 니 다.
//
public CountDownLatch(int count) {
if (count < 0) throw new IllegalArgumentException("count < 0");
this.sync = new Sync(count);
}
//
private static final class Sync extends AbstractQueuedSynchronizer {
//
Sync(int count) {
setState(count);
}
//
int getCount() {
return getState();
}
//
// ：
// ： ,
// ： ,
protected int tryAcquireShared(int acquires) {
return (getState() == 0) ? 1 : -1;
}
//
protected boolean tryReleaseShared(int releases) {
for (;;) {
//
int c = getState();
// 0,
if (c == 0) {
return false;
}
// 1
int nextc = c-1;
// CAS
if (compareAndSetState(c, nextc)) {
return nextc == 0;
}
}
}
}
// , 0,
public void await() throws InterruptedException {
//
sync.acquireSharedInterruptibly(1);
}
// ( )
public final void acquireSharedInterruptibly(int arg) throws InterruptedException {
// ,
if (Thread.interrupted()) {
throw new InterruptedException();
}
//1.
if (tryAcquireShared(arg) < 0) {
//2.
doAcquireSharedInterruptibly(arg);
}
}
//
public void countDown() {
sync.releaseShared(1);
}
// ( )
public final boolean releaseShared(int arg) {
//1.
if (tryReleaseShared(arg)) {
//2.
doReleaseShared();
return true;
}
return false;
}
응용 장면:환락 투 지 주 를 할 때 세 명의 유저 가 모두 도착 해 야 카드 를 발급 할 수 있 습 니 다.
public class Player extends Thread {
private static int count = 1;
private final int id = count++;
private CountDownLatch latch;
public Player(CountDownLatch latch) {
this.latch = latch;
}
@Override
public void run() {
System.out.println("【 " + id + "】 ");
latch.countDown();
}
public static void main(String[] args) throws InterruptedException {
CountDownLatch latch = new CountDownLatch(3);
System.out.println(" , ...");
new Player(latch).start();
new Player(latch).start();
new Player(latch).start();
latch.await();
System.out.println(" , ...");
}
}
실행 결과 카드 발급 작업 은 모든 유저 가 입장 한 후에 야 진행 되 는 것 으로 나 타 났 다.우 리 는 23 줄 의 latch.awit()주석 을 없 애고 결 과 를 비교 해 보 겠 습 니 다.
latch.awat()줄 을 주석 한 후에 모든 유저 가 입장 한 후에 야 카드 를 보 낼 수 있 음 을 보증 할 수 없습니다.
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
JPA + QueryDSL 계층형 댓글, 대댓글 구현(2)이번엔 전편에 이어서 계층형 댓글, 대댓글을 다시 리팩토링해볼 예정이다. 이전 게시글에서는 계층형 댓글, 대댓글을 구현은 되었지만 N+1 문제가 있었다. 이번에는 그 N+1 문제를 해결해 볼 것이다. 위의 로직은 이...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
