Java에서 ThreadPoolExecutor 동시 호출에 대한 예제 코드 분석

이 글은 Java ThreadPoolExecutor 동시 호출 인스턴스에 대한 자세한 설명을 중심으로 소개하고 있으니 필요하신 분들은 참고하시면 됩니다.

Java ThreadPoolExecutor 동시 호출 인스턴스에 대한 자세한 설명

개요

일반적으로 작업의 처리 속도를 향상시키기 위해 ThreadPoolExecutor에서 일부 동시성 모델 을 사용하고 informAll을 사용하는 것이 하나입니다.

Code

package test.current;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

public class TestCallable {

  public static void main(String[] args) throws InterruptedException, ExecutionException {

    List<Callable<List<Long>>> tasks = new ArrayList<>();
    for (int i = 0; i < 10; i++) {
      Callable<List<Long>> task = new Callable<List<Long>>() {
        @Override
        public List<Long> call() throws Exception {
          return Arrays.asList(1L,2L);
        }
      };

      tasks.add(task);
    }

    List<Long> finalResults = new ArrayList<>(10);
    List<Future<List<Long>>> results = ThreadPool.getThreadPool().invokeAll(tasks);
    for(Future<List<Long>> ele : results) {
      List<Long> list = ele.get();
      finalResults.addAll(list);
    }

    System.out.println(finalResults);
  }
}

package test.current;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPool {
  private static final int CORE_SIZE = 8;

  private static final int MAX_SIZE = 12;

  private static final long KEEP_ALIVE_TIME = 30;

  private static final int QUEUE_SIZE = 50000;

  private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(CORE_SIZE, MAX_SIZE, KEEP_ALIVE_TIME,
      TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(QUEUE_SIZE), new ThreadPoolExecutor.AbortPolicy());

  public static ThreadPoolExecutor getThreadPool() {
    return threadPool;
  }
}

는 실행해야 하는 작업에 대해 Callable 작업을 생성하고 스레드 풀의 스레드를 사용하여 이러한 작업을 동시에 실행함으로써 작업의 실행 효율성을 향상시킬 수 있습니다.

위 내용은 Java에서 ThreadPoolExecutor 동시 호출에 대한 예제 코드 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!