Java 스레드 풀 프레임워크

이 글에서는 주로 Java 스레드 풀 프레임워크 관련 지식을 소개합니다. 참고할만한 가치가 매우 높으니 아래 에디터로 살펴보겠습니다

1. 스레드 풀 구조도

2. 예

스레드 인터페이스 정의

public class MyThread extends Thread {
 @Override
 publicvoid run() {
 System.out.println(Thread.currentThread().getName() + "正在执行");
 }
}

1: newSingleThreadExecutor

ExecutorService pool = Executors. newSingleThreadExecutor();
 Thread t1 = new MyThread();
 Thread t2 = new MyThread();
 Thread t3 = new MyThread();
 //将线程放入池中进行执行
 pool.execute(t1);
 pool.execute(t2);
 pool.execute(t3);
 //关闭线程池
 pool.shutdown();

입력 결과:

pool-1-thread-1正在执行
pool-1-thread-1正在执行
pool-1-thread-1正在执行

2: newFixedThreadPool

ExecutorService pool = Executors.newFixedThreadPool(3);
Thread t1 = new MyThread();
 Thread t2 = new MyThread();
 Thread t3 = new MyThread();
 Thread t4 = new MyThread();
 Thread t5 = new MyThread();
 //将线程放入池中进行执行
 pool.execute(t1);
 pool.execute(t2);
 pool.execute(t3);
 pool.execute(t4);
 pool.execute(t5);
pool.shutdown();

입력 결과:

pool-1-thread-1正在执行
pool-1-thread-2正在执行
pool-1-thread-1正在执行
pool-1-thread-2正在执行

3: newCachedThreadPool

ExecutorService pool = Executors.newCachedThreadPool();
 Thread t1 = new MyThread();
 Thread t2 = new MyThread();
 Thread t3 = new MyThread();
 Thread t4 = new MyThread();
 Thread t5 = new MyThread();
 //将线程放入池中进行执行
 pool.execute(t1);
 pool.execute(t2);
 pool.execute(t3);
 pool.execute(t4);
 pool.execute(t5);
 //关闭线程池
 pool.shutdown();

입력 결과:

pool-1-thread-2正在执行
pool-1-thread-4正在执行
pool-1-thread-3正在执行
pool-1-thread-1正在执行
pool-1-thread-5正在执行

4: ScheduledThreadPoolExecutor

ScheduledExecutorService pool = Executors.newScheduledThreadPool(2);
pool.scheduleAtFixedRate(new Runnable() {//每隔一段时间就触发异常
  @Override
  public void run() {
   //throw new RuntimeException();
   System.out.println("================");
  }
 }, 1000, 2000, TimeUnit.MILLISECONDS);
pool.scheduleAtFixedRate(new Runnable() {//每隔一段时间打印系统时间，证明两者是互不影响的
  @Override
  public void run() {
   System.out.println("+++++++++++++++++");
  }
 }, 1000, 2000, TimeUnit.MILLISECONDS);

입력 결과:

================
+++++++++++++++++
+++++++++++++++++
+++++++++++++++++

3. 스레드 풀 코어 매개변수

corePoolSize: 풀의 코어 스레드 수

maximumPoolSize: 최대 풀 번호에 스레드가 허용됩니다.

keepAliveTime: 스레드 수가 코어보다 큰 경우 초과 유휴 스레드가 종료되기 전에 새 작업을 기다리는 최대 시간입니다.

단위: keepAliveTime 매개변수의 시간 단위입니다.

workQueue: 실행 전 작업을 보관하는 데 사용되는 대기열입니다. 이 큐에는 실행 메소드에 의해 제출된 실행 가능한 작업만 보관됩니다.

threadFactory: 실행자가 새 스레드를 생성하는 데 사용하는 팩토리입니다.

handler: 스레드 범위 및 대기열 용량 초과로 인해 실행이 차단될 때 사용되는 핸들러입니다.

ThreadPoolExecutor: Executors 클래스의 기본 구현입니다.

3.1 작업 대기열 메커니즘

SynchronousQueue: 동기 대기열, 대기열을 유지하지 않고 스레드에 직접 제출하여 실행합니다. , 스레드 풀은 일반적으로 Unbounded

LinkedBlockingQueue: 스레드 풀 스레드 수가 최대 수에 도달하면 새 작업이 실행을 위해 대기열에서 대기하므로 대기열이 무한정 확장될 수 있습니다

ArrayBlockingQueue: 제한된 대기열은 상한선에 도달하면 새 작업이 손실될 수 있습니다.

참고:

newSingleThreadExecutor 및 newFixedThreadPool의 사용은 LinkedBlockingQueue입니다

newCachedThreadPool은 SynchonousQueue를 사용합니다

newScheduledThreadPool은 DelayedWorkQueue를 사용합니다

3.2 스레드 실행 프로세스

3.3 스레드 크기 결정:

Cpu 집약적: 가능한 적은 수의 스레드 열기, 최적의 수 스레드 수는 Ncpu+ 1

io 집약적: 여러 스레드, 2Ncpu

혼합: 상황에 따라 io 집약적, cou 집약적으로 나눌 수 있음

더 많은 Java 스레드 풀 프레임워크 관련 기사를 보려면 PHP 중국어 웹사이트를 주목하세요!