간단 한 압력 측정 시 뮬 레이 션
import java.time.Duration;
import java.time.LocalDateTime;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicInteger;
public class CountExample {
private static final int clientTotal = 5000;
private static final int threadTotal = 8;
private static AtomicInteger count = new AtomicInteger(0);
public static void main(String... args) {
ExecutorService executorService = Executors.newFixedThreadPool(threadTotal);
final CountDownLatch latch = new CountDownLatch(clientTotal);
final Semaphore semaphore = new Semaphore(threadTotal);
LocalDateTime start = LocalDateTime.now();
for (int i = 0; i < clientTotal; i++) {
executorService.execute(() -> {
try {
semaphore.acquire();
add();
System.out.println(String.format("add() invoked by %s => %d", Thread.currentThread().getName(), count.get()));
semaphore.release();
latch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
try {
latch.await();
LocalDateTime end = LocalDateTime.now();
System.out.println(String.format("cost time millis : %d", Duration.between(start, end).toMillis()));
executorService.shutdown();
System.out.println(String.format("count:%d", count.intValue()));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
private static void add() {
count.getAndIncrement();
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Is Eclipse IDE dying?In 2014 the Eclipse IDE is the leading development environment for Java with a market share of approximately 65%. but ac...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.