인프런 커뮤니티 질문&답변

안녕하세요?

루키스님 강의를 참고하여 더미 프로젝트 하는 중에 문제가 식별 되어

제가 분석한게 맞다면 강의 코드에 문제가 있어 제보 드려봅니다.

문제라고 생각되는 부분은 JobQueue 클래스인데요,

문제 상황은

'워커스레드를 2개 이상 돌릴 때, Execute()함수가 실행되지 않는'점을 확인하였습니다.

jobCount 관련 변수의 조건이 어디서 안 맞는 것 같아서 생각해보건데,

아래와 같은 경우라고 생각됩니다.

// JobQueue.cpp
void JobQueue::Execute()
{
	...
		if (_jobCount.fetch_sub(jobCount) == jobCount)
		{
			// 여기서 다른 워커 스레드의 _jobCount.fetch_add 발생?! 
			LCurrentJobQueue = nullptr;
			return;
		}

		...
	}
}

그렇기 때문의 이후의 잡들이 처리되지 못하고 해당 부분에서 prevCount가 계속 쌓이고 있었습니다.

// JobQueue.cpp
void JobQueue::Push(JobRef job, bool pushOnly)
{
	const int32 prevCount = _jobCount.fetch_add(1);
	_jobs.Push(job); // WRITE_LOCK

	// 여기서 prevCount가 계속 쌓여 0이 아님
	if (prevCount == 0)
	{
            //그러므로 이 부분의 Excute()도 실행되지 않음
	...
}

아래는 해당 클래스 cpp 전문입니다.

귀한 시간 내시어 확인해주시면 감사하겠습니다!

#include "pch.h"
#include "JobQueue.h"
#include "GlobalQueue.h"

/*--------------
	JobQueue
---------------*/

void JobQueue::Push(JobRef job, bool pushOnly)
{
	const int32 prevCount = _jobCount.fetch_add(1);
	_jobs.Push(job); // WRITE_LOCK

	// 첫번째 Job을 넣은 쓰레드가 실행까지 담당
	if (prevCount == 0)
	{
		// 이미 실행중인 JobQueue가 없으면 실행
		if (LCurrentJobQueue == nullptr && pushOnly == false)
		{
			Execute();
		}
		else
		{
			// 여유 있는 다른 쓰레드가 실행하도록 GlobalQueue에 넘긴다
			GGlobalQueue->Push(shared_from_this());
		}
	}
}

// 1) 일감이 너~무 몰리면?
void JobQueue::Execute()
{
	LCurrentJobQueue = this;

	while (true)
	{
		vector<JobRef> jobs;
		_jobs.PopAll(OUT jobs);

		const int32 jobCount = static_cast<int32>(jobs.size());
		for (int32 i = 0; i < jobCount; i++)
			jobs[i]->Execute();

		// 남은 일감이 0개라면 종료
		if (_jobCount.fetch_sub(jobCount) == jobCount)
		{
			LCurrentJobQueue = nullptr;
			return;
		}

		const uint64 now = ::GetTickCount64();
		if (now >= LEndTickCount)
		{
			LCurrentJobQueue = nullptr;
			// 여유 있는 다른 쓰레드가 실행하도록 GlobalQueue에 넘긴다
			GGlobalQueue->Push(shared_from_this());
			break;
		}			
	}
}