java에서 멀티쓰레드 [2] Executors와 ExecutorService

CompletableFuture를 알기 전에 Concurrent 프로그래밍을 꼭 알아야 한다.

Thread와 Runnable을 쓰긴 하지만 직접 쓰진 않고 고수준의 작업들을 Executors를 사용한다.

Executors로 Thread를 만들고 Runnable만 제공해주면 된다.

실제로는 Executors가 아닌 Executors를 상속받는 ExecutorService를 사용한다.

package java.util.concurrent;
public interface ExecutorService extends Executor {}

자바 5부터 제공되는 인터페이스이다.

Callable도 실행할 수 있으며, Executors를 종료시키거나, 여러 Callable을 동시에 실행하는 기능을 제공한다.

ExecutorService의 execute 메서드나 submit 메서드로 실행시킬 수 있다.

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

import static java.lang.Thread.*;

public class App {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        executorService.execute(() -> System.out.println("Thread(ExecutorService: " + currentThread().getName()));
    }
}

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

import static java.lang.Thread.*;

public class App {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        executorService.submit(() -> System.out.println("Thread(ExecutorService: " + currentThread().getName()));
    }
}

executor vs submit

• executor : Executors의 메서드고 리턴 타입이 void이다.
• submit은 ExecutorService의 메서드이고 리턴 타입이 Future이다.

쓰레드를 멈추는 방법엔 shutdown 또는 shutdownNow 메서드를 사용한다.

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

import static java.lang.Thread.*;

public class App {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        executorService.execute(() -> System.out.println("Thread(ExecutorService: " + currentThread().getName()));

        executorService.shutdown();
        executorService.shutdownNow();
    }
}

shutdown은 실행 중이던 작업을 모두 마무리하고 종료할 때 사용한다.

shutdownNow은 강제 종료할 때 사용한다.

🤔 쓰레드보다 적은 작업을 부여된다면 어떡하지?

 

위 그림처럼 블로킹 큐를 통해 작업을 쌓아둘 수 있다.

• Blocking Queue : 쓰레드가 바빠서 작업을 처리하지 못할 때 쌓아두는 저장소

schedule 메서드를 통해 작업에 딜레이도 줄 수 있다.

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

public class App {
    public static void main(String[] args) {
        ScheduledExecutorService scheduledExecutorService =  Executors.newSingleThreadScheduledExecutor();
        scheduledExecutorService.schedule(getRunnable("Hello"), 1, TimeUnit.SECONDS);
    }

    private static Runnable getRunnable(String message) {
        return () -> System.out.println(message + Thread.currentThread().getName());
    }
}

멀티프로세싱을 지원하는 Fork/Join 프레임워크도 존재한다.

이것 역시 ExecutorService의 구현체로 멀티 프로세서를 활용할 수 있게 도와주는 도구이다.

다음에는 위에 submit 메서드에서 언급된 Future과 Callable을 배워본다.