[ 스레드 풀 이해와 구현 ] 예시코드 버그

선생님 안녕하세요. 강의를 듣다가 조금 이상한 부분이 있어서 문의드립니다.

[ 스레드 풀 이해와 구현 ] 강의에서 작성하는 코드를 저도 그대로 따라치면서 실습을 하고 있는데요.
그런데 예시 코드의 동작에 약간의 문제를 발견했습니다.

강의에서 보여주는 코드는 아래와 WorkerThread 코드는 아래와 같습니다.

그런데 제가 한 ThreadPoolMain 클래스에서 Task 를 3000 개 정도 주고, ThreadPoolSize =20 을 주고 돌려보니까, 2가지 이상현상을 확인했습니다.

1. Null Poiniter Exception 발생

2. 중복 처리

각각의 문제가 발생하는 이유를 정리해보니 다음과 같더라구요.

• NPE 발생 원인

// 시나리오 1
if (!taskQueue.isEmpty()) {
    // 쓰레드 A,B 2개가 동시에 여기에 접근
    // 쓰레드 A 가 먼저 Poll 을 해서 가져가버림.
    // 쓰레드 B 는 비어있는 Queue 에 대하여 poll, null 을 반환 받음
    task = taskQueue.poll();
} else {
    continue;
}
// 쓰레드 A 는 정상 시작
// 쓰레드 B 는 NullPointerException!
task.run();

• 중복처리 원인

// 시나리오 2
if (!taskQueue.isEmpty()) {
	// 쓰레드 A,B 2개가 동시에 여기에 접근
	// 쓰레드 A 가 먼저 Poll 을 해서 가져 가버림.
	// 쓰레드 B 도 Poll 해서 task 를 가져감.
	task = taskQueue.poll();
} else {
	continue;
}
// 쓰레드 A 는 작업 시작
// 쓰레드 B 도 중복으로 해당 task 실행
task.run();

혹시 코드를 아래처럼 짜야 되는 게 아닌지 조심스럽게 문의해봅니다.