ExecutorService 인터페이스

Executor 인터페이스가 필요한 이유는 무엇입니까?

Java 5 이전에는 애플리케이션에서 모든 자체 코드 스레드 관리를 작성해야 했습니다. 또한,새 스레드개체는 리소스를 많이 사용하는 작업이며 모든 경량 작업에 대해 새 스레드를 만드는 것은 이치에 맞지 않습니다. 그리고 이 문제는 멀티스레드 애플리케이션의 모든 개발자에게 친숙하기 때문에 이 기능을 Executor 프레임워크로 Java에 도입하기로 결정했습니다.

큰 아이디어는 무엇입니까? 간단합니다. 새 작업마다 새 스레드를 만드는 대신 스레드를 일종의 "저장소"에 보관하고 새 작업이 도착하면 새 작업을 만드는 대신 기존 스레드를 검색합니다.

이 프레임워크의 주요 인터페이스는 Executor , ExecutorService 및 ScheduledExecutorService 이며 각각 이전 인터페이스의 기능을 확장합니다.

Executor 인터페이스는 기본 인터페이스입니다. Runnable 개체 에 의해 구현되는 단일 무효 실행(Runnable 명령) 메서드를 선언합니다 .

ExecutorService 인터페이스 가 더 흥미롭습니다. 작업 완료를 관리하는 방법과 일종의 결과를 반환하는 방법이 있습니다. 방법을 자세히 살펴 보겠습니다.

ExecutorService 작업에 대한 간단한 예를 살펴보겠습니다 .

import java.util.List;
import java.util.concurrent.*;

public class ExecutorServiceTest {
   public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
//Create an ExecutorService for 2 threads
       java.util.concurrent.ExecutorService executorService = new ThreadPoolExecutor(2, 2, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10));
// Create 5 tasks
       MyRunnable task1 = new MyRunnable();
       MyRunnable task2 = new MyRunnable();
       MyRunnable task3 = new MyRunnable();
       MyRunnable task4 = new MyRunnable();
       MyRunnable task5 = new MyRunnable();

       final List<MyRunnable> tasks = List.of(task1, task2, task3, task4, task5);
// Pass a list that contains the 5 tasks we created
       final List<Future<Void>> futures = executorService.invokeAll(tasks, 6, TimeUnit.SECONDS);
       System.out.println("Futures received");

// Stop the ExecutorService
       executorService.shutdown();

       try {
           TimeUnit.SECONDS.sleep(3);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }

       System.out.println(executorService.isShutdown());
       System.out.println(executorService.isTerminated());
   }

   public static class MyRunnable implements Callable<Void> {

       @Override
       public void call() {
// Add 2 delays. When the ExecutorService is stopped, we will see which delay is in progress when the attempt is made to stop execution of the task
           try {
               TimeUnit.SECONDS.sleep(3);
           } catch (InterruptedException e) {
               System.out.println("sleep 1: " + e.getMessage());
           }
           try {
               TimeUnit.SECONDS.sleep(2);
           } catch (InterruptedException e) {
               System.out.println("sleep 2: " + e.getMessage());
           }
           System.out.println("done");
           return null;
       }
   }
}

산출:

각 작업은 5초 동안 실행됩니다. 우리는 두 개의 스레드에 대한 풀을 만들었으므로 처음 두 줄의 출력이 완벽하게 이해됩니다.

프로그램이 시작되고 6초 후에 invokeAll 메서드가 시간 초과되고 결과가 Futures 목록으로 반환됩니다 . 이것은 출력 문자열 Futures received 에서 볼 수 있습니다 .

처음 두 가지 작업이 완료되면 두 가지 작업이 더 시작됩니다. 하지만 invokeAll 메서드에 설정된 제한 시간이 경과하기 때문에 이 두 작업은 완료할 시간이 없습니다. 그들은 "취소" 명령을 받습니다. 이것이 출력에 sleep 1: sleep interrupted 가 포함된 두 줄이 있는 이유입니다 .

그런 다음 done 이 있는 두 줄을 더 볼 수 있습니다 . 이것이 invokeAll 메서드를 설명할 때 언급한 부작용입니다 .

다섯 번째이자 마지막 작업은 시작조차 되지 않으므로 출력에 아무것도 표시되지 않습니다.

마지막 두 줄은 isShutdown 및 isTerminated 메서드를 호출한 결과입니다 .

디버그 모드에서 이 예제를 실행하고 시간 제한이 경과한 후 작업 상태를 살펴보는 것도 흥미롭습니다( executorService.shutdown(); 을 사용하여 줄에 중단점을 설정 ).

두 개의 작업이 정상적으로 완료되고 세 개의 작업이 "취소됨" 인 것을 볼 수 있습니다 .

ScheduledExecutorService

실행자에 대한 논의를 마치기 위해 ScheduledExecutorService 를 살펴보겠습니다 .

4가지 방법이 있습니다.