이 ThreadPoolExecutor클래스는 여러 Executors팩토리 메소드 에서 리턴되는 실행 프로그램의 기본 구현입니다 . 이제 고정 및 캐시 스레드 풀에 접근하십시오 ThreadPoolExecutor.

ThreadPoolExecutor

이 클래스 의 주요 생성자 는 다음과 같습니다.

public ThreadPoolExecutor(
                  int corePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime,
                  TimeUnit unit,
                  BlockingQueue<Runnable> workQueue,
                  ThreadFactory threadFactory,
                  RejectedExecutionHandler handler
)

코어 풀 크기

는 corePoolSize타겟 스레드 풀의 최소 사이즈를 결정한다. 실행할 작업이 없더라도 구현은 해당 크기의 풀을 유지합니다.

최대 수영장 크기

는 maximumPoolSize한 번에 활성화 할 수있는 스레드의 최대 수입니다.

스레드 풀이 커지고 corePoolSize임계 값 보다 커지면 실행자는 유휴 스레드를 종료하고 corePoolSize다시 도달 할 수 있습니다 . allowCoreThreadTimeOuttrue 인 경우 실행 프로그램이 코어 풀 스레드가 keepAliveTime임계 값 보다 유휴 상태 인 경우 코어 풀 스레드를 종료 할 수도 있습니다 .

결론은 스레드가 keepAliveTime임계 값 이상으로 유휴 상태로 유지되면 스레드 가 필요하지 않기 때문에 종료 될 수 있다는 것입니다.

큐잉

새 작업이 시작되고 모든 코어 스레드가 사용되면 어떻게됩니까? 새 작업이 해당 BlockingQueue<Runnable>인스턴스 내에서 대기 합니다. 스레드가 사용 가능 해지면 대기중인 태스크 중 하나를 처리 할 수 ​​있습니다.

BlockingQueueJava 에는 다양한 인터페이스 구현이 있으므로 다음과 같은 다른 큐잉 접근 방식을 구현할 수 있습니다.

1. 바운드 대기열 : 새로운 작업이 바운드 작업 대기열에 대기됩니다.

2. 무제한 대기열 : 새로운 작업은 무제한 작업 대기열 내에 대기합니다. 따라서이 큐는 힙 크기가 허용하는만큼 커질 수 있습니다.

3. 동기식 핸드 오프 :를 사용 SynchronousQueue하여 새 작업을 대기열에 넣을 수도 있습니다 . 이 경우 새 작업을 대기열에 넣을 때 다른 스레드가 이미 해당 작업을 기다리고 있어야합니다.

작품 제출

ThreadPoolExecutor새로운 작업을 수행하는 방법은 다음과 같습니다 .

1. corePoolSize실행중인 스레드 수보다 적은 수의 경우 주어진 작업을 첫 번째 작업으로하여 새 스레드를 시작하려고합니다.
2. 그렇지 않으면 BlockingQueue#offer메소드를 사용하여 새 태스크를 큐에 넣습니다
   . offer큐가 즉시 반환 가득하고 있다면 방법은 차단하지 않습니다 false.
3. 새 작업을 대기열에 넣지 못하면 (즉 ,을 offer반환 false)이 작업을 첫 번째 작업으로하여 스레드 풀에 새 스레드를 추가하려고합니다.
4. 새 스레드를 추가하지 못하면 실행 프로그램이 종료되었거나 포화 상태입니다. 어느 쪽이든, 새로운 작업은 제공된를 사용하여 거부됩니다 RejectedExecutionHandler.

고정 스레드 풀과 캐시 스레드 풀의 주요 차이점은 다음 세 가지 요소로 요약됩니다.

1. 코어 풀 크기
2. 최대 수영장 크기
3. 큐잉

+ ----------- + ----------- + ------------------- + ----- ---------------------------- +
| 풀 타입 | 코어 크기 | 최대 크기 | 큐잉 전략 |
+ ----------- + ----------- + ------------------- + ----- ---------------------------- +
| 고정 | n (고정) | n (고정) | 무제한`LinkedBlockingQueue` |
+ ----------- + ----------- + ------------------- + ----- ---------------------------- +
| 캐시 | 0 | 정수 .MAX_VALUE | `SynchronousQueue` |
+ ----------- + ----------- + ------------------- + ----- ---------------------------- +

---

고정 스레드 풀

---

Excutors.newFixedThreadPool(n)작동
방식은 다음과 같습니다 .

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

보다시피 :

• 스레드 풀 크기는 고정되어 있습니다.
• 수요가 많으면 성장하지 않습니다.
• 스레드가 꽤 오랫동안 유휴 상태이면 축소되지 않습니다.
• 모든 스레드가 오래 실행되는 작업으로 채워져 있고 도착률이 여전히 높다고 가정하십시오. 실행 프로그램이 무제한 큐를 사용하고 있기 때문에 힙의 상당 부분을 소비 할 수 있습니다. 불행히도, 우리는 경험할 수 있습니다 OutOfMemoryError.

언제 하나를 사용해야합니까? 리소스 활용 측면에서 어떤 전략이 더 낫습니까?

리소스 관리 목적으로 동시 작업 수를 제한하려는 경우 고정 크기 스레드 풀이 적합한 후보로 보입니다 .

예를 들어, 실행기를 사용하여 웹 서버 요청을 처리하려는 경우 고정 실행자는 요청 버스트를보다 합리적으로 처리 할 수 ​​있습니다.

더 나은 자원 관리를 위해, 매우 사용자 정의 만들 것을 추천 ThreadPoolExecutor바운드와 BlockingQueue<T>합리적인 결합 구현 RejectedExecutionHandler.

---

캐시 된 스레드 풀

---

Executors.newCachedThreadPool()작동 방식은 다음과 같습니다 .

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

보다시피 :

• 스레드 풀은 0 스레드에서으로 증가 할 수 있습니다 Integer.MAX_VALUE. 실제로 스레드 풀은 제한이 없습니다.
• 스레드가 1 분 이상 유휴 상태이면 종료 될 수 있습니다. 따라서 스레드가 너무 유휴 상태 인 경우 풀이 축소 될 수 있습니다.
• 새 작업이 들어올 때 할당 된 모든 스레드가 사용되면 다른 스레드 SynchronousQueue에 수락 할 수있는 사람이없는 경우 항상 새 작업을 제공 할 수 없으므로 새 스레드가 생성 됩니다.

언제 하나를 사용해야합니까? 리소스 활용 측면에서 어떤 전략이 더 낫습니까?

예측 가능한 단기 실행 작업이 많을 때 사용하십시오.

---

답변