Java ThreadPool Example

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
import java.util.Date;
import java.util.concurrent.*;

public class ObjectTest {
public static void main(String[] args) {
Future future = null;

// ExecutorService 인터페이스 구현객체 Executors 정적메서드를 통해 최대 스레드 개수가 2인 스레드 풀 생성
ExecutorService executorService = Executors.newFixedThreadPool(5);

for (int i = 0; i < 10; i++) {
Runnable runnable = new Runnable() {
@Override
public void run() {
//스레드에게 시킬 작업 내용
ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executorService;

int poolSize = threadPoolExecutor.getPoolSize();//스레드 풀 사이즈 얻기
String threadName = Thread.currentThread().getName();//스레드 풀에 있는 해당 스레드 이름 얻기
System.out.println("[총 스레드 개수:" + poolSize + "] 작업 스레드 이름: " + threadName);

//일부로 예외 발생 시킴
// int value = Integer.parseInt("예외");
try {
Thread.sleep(5000);
System.out.println(new Date().toString());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};

//스레드풀에게 작업 처리 요청
// executorService.execute(runnable);
future = executorService.submit(runnable);
}

try {
future.get();
System.out.println("[작업 처리 완료]");
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
//스레드풀 종료
executorService.shutdown();
System.out.println("Finish");

}

}
공유하기