스레드 풀을 생성하는 네 가지 방법은 무엇입니까?-Java베이스-php.cn

스레드 풀을 생성하는 네 가지 방법은 무엇입니까?

青灯夜游

풀어 주다： 2023-01-13 00:39:43

원래의

34405명이 탐색했습니다.

메서드: newCachedThreadPool은 캐시 가능한 스레드 풀을 생성하고, newFixedThreadPool은 고정 길이 스레드 풀을 생성하고, newScheduledThreadPool은 고정 길이 스레드 풀을 생성하며, newSingleThreadExecutor는 단일 스레드 스레드 풀을 생성합니다.

스레드 풀을 생성하는 네 가지 방법은 무엇입니까?

4가지 스레드 풀 생성 방법

Java는 Executor를 통해 다음과 같은 4가지 스레드 풀을 제공합니다.

1 newCachedThreadPool

newCachedThreadPool을 사용하여 캐시 가능한 스레드 풀을 만듭니다. 만약 스레드 풀 길이가 처리 요구 사항을 초과하면 유휴 스레드를 유연하게 재활용할 수 있으면 새 스레드가 생성됩니다.

이 유형의 스레드 풀의 특징은 다음과 같습니다.

생성되는 작업자 스레드 수에는 거의 제한이 없습니다(실제로는 제한이 있으며 개수는 Interger. MAX_VALUE입니다). 스레드 풀에 유연하게 추가되었습니다.
오랜 시간 동안 스레드 풀에 작업이 제출되지 않은 경우, 즉 작업자 스레드가 지정된 시간(기본값은 1분) 동안 유휴 상태이면 작업자 스레드가 자동으로 종료됩니다. 종료 후 새 작업을 제출하면 스레드 풀이 작업자 스레드를 다시 생성합니다.
CachedThreadPool 사용 시 작업 개수 조절에 주의해야 합니다. 그렇지 않으면 동시에 실행되는 스레드 수가 많아 시스템이 마비될 수 있습니다.

샘플 코드는 다음과 같습니다.

 package test;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
   public class ThreadPoolExecutorTest {
   public static void main(String[] args) {
   ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
  for (int i = 0; i < 10; i++) {
   final int index = i;
    try {
    Thread.sleep(index * 1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    cachedThreadPool.execute(new Runnable() {
     public void run() {
      System.out.println(index);
     }
    });
   }
  }
 }

로그인 후 복사

2. newFixedThreadPool

을 사용하여 지정된 수의 작업자 스레드로 스레드 풀을 만듭니다. 작업이 제출될 때마다 작업자 스레드가 생성됩니다. 작업자 스레드 수가 스레드 풀의 초기 최대 수에 도달하면 제출된 작업이 풀 큐에 저장됩니다.

FixedThreadPool은 스레드 풀의 대표적인 장점으로 프로그램 효율성을 향상시키고 스레드 생성 시 오버헤드를 줄여준다는 장점이 있습니다. 그러나 스레드 풀이 유휴 상태인 경우, 즉 스레드 풀에 실행 가능한 작업이 없는 경우 작업자 스레드를 해제하지 않고 특정 시스템 리소스도 점유하게 됩니다.

샘플 코드는 다음과 같습니다.

 package test;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 public class ThreadPoolExecutorTest {
  public static void main(String[] args) {
   ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
   for (int i = 0; i < 10; i++) {
    final int index = i;
    try {
     Thread.sleep(index * 1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    cachedThreadPool.execute(new Runnable() {
     public void run() {
      System.out.println(index);
     }
    });
   }
  }
 }

로그인 후 복사

스레드 풀 크기가 3이기 때문에 각 작업은 인덱스 출력 후 2초 동안 sleep하므로 2초마다 3개의 숫자가 출력됩니다.

고정 길이 스레드 풀의 크기는 Runtime.getRuntime().availableProcessors()와 같은 시스템 리소스에 따라 설정하는 것이 가장 좋습니다.

3. newSingleThreadExecutor

를 사용하여 단일 스레드 실행자를 만듭니다. 즉, 작업을 실행하기 위해 고유한 작업자 스레드만 생성하여 모든 작업이 실행되도록 합니다. 지정된 순서(FIFO, LIFO, 우선순위) 실행. 이 스레드가 비정상적으로 종료되면 순차적 실행을 보장하기 위해 다른 스레드가 이를 대체합니다. 단일 작업자 스레드의 가장 큰 특징은 작업이 순차적으로 실행되고 특정 시간에 여러 스레드가 활성화되지 않도록 할 수 있다는 것입니다.

샘플 코드는 다음과 같습니다.

package test;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExecutorTest {
 public static void main(String[] args) {
  ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
  for (int i = 0; i < 10; i++) {
   final int index = i;
   singleThreadExecutor.execute(new Runnable() {
    public void run() {
     try {
      System.out.println(index);
      Thread.sleep(2000);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
   });
  }
 }
}

로그인 후 복사

4. newScheduledThreadPool

을 사용하여 고정 길이 스레드 풀을 생성하고 예약 및 주기적인 작업 실행을 지원하며 예약 및 주기적인 작업 실행을 지원합니다.

3초 지연 실행 지연 실행 샘플 코드는 다음과 같습니다.

package test;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest {
 public static void main(String[] args) {
  ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
  scheduledThreadPool.schedule(new Runnable() {
   public void run() {
    System.out.println("delay 3 seconds");
   }
  }, 3, TimeUnit.SECONDS);
 }
}

로그인 후 복사

는 1초 지연 후 3초마다 실행된다는 의미입니다. 일반 실행 샘플 코드는 다음과 같습니다.

package test;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest {
 public static void main(String[] args) {
  ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
  scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
   public void run() {
    System.out.println("delay 1 seconds, and excute every 3 seconds");
   }
  }, 1, 3, TimeUnit.SECONDS);
 }
}

로그인 후 복사

자세한 프로그래밍은 다음과 같습니다. 관련 지식은 프로그래밍 학습 웹사이트를 방문하세요! !

위 내용은 스레드 풀을 생성하는 네 가지 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!