Java 자바에서 Thread 쓰레드 및 쓰레드 풀 ThreadPoolExecutor 사용 방법

Java 언어에서 Thread 를 하나 새로 생성해서 실행하기 위해 Thread 를 상속한 클래스를 만들면 된다.

이 클래스는 기본적으로 run() 함수를 구현해야 하는데, 다음과 같이 구현할 수 있다.

static class th extends Thread{ @Override public void run() { while(true) { try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("OK"); } } }

즉 Thread 를 상속받는 클래스를 생성한 뒤에 해당 클래스를 인스턴스화 한 뒤 .start() 로 쓰레드를 실행할 수 있다.

위 코드는 a, b 가 동시에 실행되는 것을 볼 수 있다.

이외 작업을 쓰레드 풀에 담아 순차적으로 처리할 수 있도록 하는 클래스가 있는데 바로 ThreadPoolExecutor이다. ThreadPoolExecutor 은 기본 생성자 인자로 활성 쓰레드 개수, 최대 쓰레드 개수, 유휴 시간, 유휴 시간 유닛, 블럭킹 큐 리스트를 순서대로 받는다.

ThreadPoolExecutor executor= new ThreadPoolExecutor(2, 4, 5, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());

즉 기본 활성 쓰레드에 배치하여 작업을 수행하고 최대 쓰레드 개수까지 늘어날 수 있는 것이다. 위 executor 을 생성하면 원하는 작업을 대기열에 담아둘 수 있는데, 할당된 쓰레드 개수에 맞춰서 먼저 요청된 쓰레드가 실행되고 앞의 작업이 끝나면 다음 쓰레드가 순차적으로 실행된다.

쓰레드 실행을 요청하기 위해서 executor.execute(Runnable); 을 사용하면 된다. Runnable 은 implements 하면 되기 때문에, 클래스를 선언한 뒤 Runnable 을 implements 하여 run 을 구현한 다음 생성하여 사용하면 된다.

즉 위 코드에서, execute 되는 요청은 5개로 쓰레드 2개를 훨씬 초과하지만 우선 모두 대기열에 쌓인 다음, a, b 요청부터 차례로 실행한다. 쓰레드가 끝나면 다음 쓰레드가 실행된다. 진행 과정은 아래 결과를 보면 확인할 수 있다.

OK! [b] OK [a] OK [a] OK [b] OK [b] OK [a] OK [b] OK [a] OK [b] OK [a] OK [c] OK [d] OK [c] OK [d] OK [c] OK [d] OK [d] OK [c] OK [c] OK [d] OK [e] OK [e] OK [e] OK [e] OK [e] OK