모두의 관심사

Java ThreadPoolExecutor와 ExecutorCompletionService를 활용한 작업 완료 처리 방법을 살펴보자.

Java ThreadPoolExecutor란 무엇인가?

Java에서 ThreadPoolExecutor는 스레드를 생성하고 관리하며 작업에 대한 실행을 제공하는 클래스입니다. 이 클래스는 작업을 수행하는 스레드 풀을 구현하고, 작업 큐를 관리하며, 작업 스케줄링을 처리하는 기능을 갖추고 있습니다. 이 클래스는 간단한 초기화 후에 작업을 제출하고 작업이 완료될 때까지 대기할 수 있습니다.

ExecutorCompletionService의 역할은 무엇인가?

ExecutorCompletionService는 ExecutorService 인터페이스를 구현하는 클래스입니다. 이 클래스는 실행 중인 작업의 완료를 처리하는 기능을 제공합니다. 작업이 완료되면 먼저 완료된 작업의 Future 객체를 반환합니다. 이러한 방식으로 ExecutorCompletionService는 작업 완료 시점을 기다리지 않고 작업 결과를 즉시 확인할 수 있습니다.

작업 완료 처리 방법을 이해해 보자

작업 완료 처리를 위해서는 ExecutorCompletionService를 사용해야 합니다. 이 클래스는 작업 완료 시점을 기다리지 않고 작업 결과를 즉시 확인할 수 있기 때문입니다. 각 작업은 Future 객체를 반환하므로, 작업이 완료될 때까지 이 객체를 유지하면 됩니다.

작업 완료 처리를 위해선 ExecutorCompletionService.poll() 메서드를 사용하면 됩니다. 이 메서드는 작업이 완료된 경우 Future 객체를 반환하며, 작업이 완료되지 않은 경우 null을 반환합니다. 작업이 완료된 순서대로 Future 객체를 반환하기 때문에, 작업이 완료되는 대로 결과를 처리할 수 있습니다.

Java ThreadPoolExecutor와 ExecutorCompletionService의 활용 방법

Java ThreadPoolExecutor와 ExecutorCompletionService를 함께 사용하면 작업 완료 처리를 쉽게 구현할 수 있습니다. 다음은 간단한 예제 코드입니다.

ExecutorService executor = Executors.newFixedThreadPool(4);
ExecutorCompletionService completionService = new ExecutorCompletionService(executor);

for (int i = 1; i  {
        Thread.sleep(index * 1000);
        return "Task " + index + " completed";
    });
}

for (int i = 1; i <= 10; i++) {
    Future result = completionService.poll(1, TimeUnit.SECONDS);
    if (result != null) {
        System.out.println(result.get());
    }
}

위 코드에서는 ThreadPoolExecutor를 사용해 4개의 스레드로 작업을 수행합니다. ExecutorCompletionService를 사용해 작업을 제출하고, 작업이 완료될 때마다 결과를 출력합니다.

Java ThreadPoolExecutor와 ExecutorCompletionService는 작업 완료 처리를 쉽게 구현할 수 있는 강력한 기능입니다. 이 두 클래스를 함께 사용하여 작업을 처리하면, 작업 완료 시점을 기다리지 않고 즉시 결과를 처리할 수 있습니다. 이를 통해, 다양한 작업을 효율적으로 처리할 수 있습니다.

Reference : Java ThreadPoolExecutor와 ExecutorCompletionService를 활용한 작업 완료 처리 방법