Executor 프레임워크는 스레드 풀 개념을 사용하여 설계되었습니다. 쓰레드 풀은 현재 작업을 실행할 때마다 새로운 쓰레드를 생성하지 않고 이미 생성된 쓰레드를 재사용하는 방식입니다.
Executors 클래스는 스레드 풀을 생성하는 팩토리 메서드를 제공합니다. ThreadPoolExecutor 클래스는 많은 Executors 팩토리 메서드에서 반환되는 실행기의 기본 구현입니다.
| Sr. 아니요. | 키 | 고정 스레드 풀 | 캐시된 스레드 풀 |
|---|---|---|---|
| 1 | 기본 | 자바 문서에 따라 - 공유 무제한 대기열에서 작동하는 고정된 수의 스레드를 재사용하는 스레드 풀을 만듭니다. 어느 시점에서든 기껏해야 nThreads 스레드가 활성 처리 작업이 됩니다. 모든 스레드가 활성 상태일 때 추가 작업이 제출되면 스레드를 사용할 수 있을 때까지 대기열에서 대기합니다. 종료 전에 실행 중 오류로 인해 스레드가 종료되면 후속 작업을 실행하는 데 필요한 경우 새 스레드가 그 자리를 차지합니다. 풀의 스레드는 명시적으로 종료될 때까지 존재합니다. | 자바 문서에 따라 - 필요에 따라 새 스레드를 생성하지만 이전에 생성된 스레드가 사용 가능할 때 재사용하는 스레드 풀을 생성합니다. 이러한 풀은 일반적으로 많은 단기 비동기 작업을 실행하는 프로그램의 성능을 향상시킵니다. 실행 호출은 사용 가능한 경우 이전에 구성된 스레드를 재사용합니다. 기존 스레드를 사용할 수 없으면 새 스레드가 생성되어 풀에 추가됩니다. |
| 2 | 대기열 | Blocking Queue를 사용합니다. | SynchronousQueue를 사용합니다. 대기줄 . |
| 3 | 스레드 수명 | 모든 스레드가 명시적으로 종료될 때까지 계속 실행됩니다. | 60초 동안 사용되지 않은 스레드는 종료되고 캐시에서 제거됩니다. |
| 4. | 스레드 풀 크기 | 스레드 풀 크기가 고정되어 커지지 않습니다. | 스레드 풀은 0개의 스레드에서 Integer.MAX_VALUE까지 증가할 수 있습니다. |
| 5. | 사용 사례 | 동시 작업을 제한하려면 fixedthreadpool을 사용해야 합니다. | 예측 가능한 작업이 많을 때 사용할 수 있습니다. |
고정 스레드 풀의 예
public class Main {
public static void main(String args[]) throws InterruptedException {
ExecutorService executors = Executors.newFixedThreadPool(4);
CountDownLatch latch= new CountDownLatch(2);
executors.submit(new Service1(latch));
executors.submit(new Service2(latch));
latch.await();
System.out.println("Done");
}
import java.util.concurrent.CountDownLatch;
public class Service1 implements Runnable {
CountDownLatch latch;
public Service1(CountDownLatch latch) {
super();
this.latch = latch;
}
@Override
public void run() {
try {
Thread.sleep(20000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
latch.countDown();
System.out.println("Services2"+latch.getCount());
}
}
import java.util.concurrent.CountDownLatch;
public class Service2 implements Runnable {
CountDownLatch latch;
public Service2(CountDownLatch latch) {
super();
this.latch = latch;
}
@Override
public void run() {
try {
Thread.sleep(20000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
latch.countDown();
System.out.println("Services2"+latch.getCount());
}
}