item80

스레드보다는 실행자, 태스크, 스트림을 애용하라

작업 큐를 손수 만드는 일은 삼가야 하고, 스레드를 직접 다루는 것도 일반적으로 삼가야 한다. 스레드를 직접 다루면 Thread가 작업 단위와 수행 매커니즘 역할을 모두 수행하게 된다. 반면 실행자 프레임워크에서는 작업 단위와 실행 매커니즘이 분리된다.

• 작업 큐: 수행해야 할 작업을 저장해 놓는 데이터 구조
• 스레드를 직접 다루는 것: 애플리케이션에서 직접 Thread 객체를 생성하고, 작업을 실행하는 방법을 말한다. 예를 들어, new Thread(new RunnableTask()).start();와 같은 방식으로 스레드를 생성하고 실행하는 것을 의미한다.
• 작업 단위: 스레드가 수행해야 할 실제 작업. 작업 단위는 일반적으로 Runnable이나 Callable 인터페이스를 구현한 객체로 표현된다.
• 수행 매커니즘 역할: 작업 단위를 실행하는 메커니즘을 의미한다. 이는 스레드가 작업을 처리하는 방법과 관련된 모든 것을 포함한다. 예를 들어, 스레드 풀(thread pool)은 여러 스레드를 관리하고, 큐에 있는 작업을 꺼내어 스레드에 할당하는 수행 매커니즘이다.
• 실행자 프레임워크: Java에서 제공하는 java.util.concurrent 패키지의 일부로, 작업 단위와 수행 매커니즘을 분리하여 관리하는 프레임워크이다.

실행자 프레임워크 (Executor Framework)

실행자 프레임워크

실행자 프레임워크를 사용하면, 작업 단위를 별도의 실행 메커니즘에 전달하여 비동기적으로 실행할 수 있다. 이는 개발자가 직접 스레드를 관리하지 않고도 작업을 효율적으로 처리할 수 있게 해준다.

주요 클래스 및 인터페이스

• Executor: 작업을 실행하는 기본 인터페이스
• ExecutorService: Executor를 확장하여 더 많은 기능을 제공하는 인터페이스. 작업 제출, 종료, 결과 반환 등의 기능을 제공한다.
• Executors: Executor 및 ExecutorService 인스턴스를 생성할 수 있는 유틸리티 클래스

사용 예시

package com.example.executor;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 스레드 풀 생성 (고정된 크기: 5개의 스레드)
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 10개의 작업 제출
        for (int i = 1; i <= 10; i++) {
            Task task = new Task(i);
            executorService.submit(task);
        }

        // ExecutorService 종료 요청
        executorService.shutdown();

        try {
            // 모든 작업이 완료될 때까지 대기
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                executorService.shutdownNow(); // 아직 실행 중인 작업을 강제 종료
                if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                    System.err.println("ExecutorService did not terminate");
                }
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
            Thread.currentThread().interrupt();
        }

        System.out.println("All tasks completed.");
    }

		static class Task implements Runnable {
		    private final int taskId;
		
		    public Task(int taskId) {
		        this.taskId = taskId;
		    }
		
		    @Override
		    public void run() {
		        System.out.println("Task ID: " + this.taskId + " performed by " + Thread.currentThread().getName());
		        try {
		            // 작업 시뮬레이션을 위한 대기
		            Thread.sleep(1000);
		        } catch (InterruptedException e) {
		            Thread.currentThread().interrupt();
		            System.out.println("Task ID: " + this.taskId + " was interrupted");
		        }
		    }
		}
}