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

강사님 제가 이해한 부분이 맞는지 궁금합니다.

 

제가 처음에 이해한 부분입니다.

1. Consumer에서 먼저 잡은 lock을 한 경우 unlock 후 대기, Producer에서 lock을 하고 push한 후, cv.notify_one()을 실행한다.

2. Consumer에서 먼저 잡은 경우는 cv.wait()에서 lock을 걸고 진행하고, 늦게 잡은 경우도 unique_lock에서 lock을 건다.

3. Consumer에서 끝나면 Producer는 이미 계속 lock을 걸려고 하고 있으므로, 1, 2번을 반복한다.

 

위의 경우라면 큐의 사이즈가 0 1 0 1 0 1...이 반복되서 결과 값이 0 0 0 0... 이 된다고 생각했습니다. 하지만 결과 값은 확 늘었다가 1씩 줄어들다가 또 확 늘었다가 1씩 줄어들다를 반복하였습니다.(결과적으로 몇천, 몇만, 몇십만까지 증가하였습니다.)

 

코드의 첫 번째 주석대로 Producer를 기준으로 큐의 사이즈 값을 출력하니 0 0 0 0... 까지는 아니지만 모든 수가 4미만으로 나옵니다.

 

Producer에서 lock을 해제할 경우 Consumer에서 접근이 가능하지만 조건이 걸려있어 0미만으로는 가지 않을 것이고, Consumer에서 lock을 해제할 경우 Producer에서 여러 번 값을 넣는 경우라면 이해는 갑니다.

 

위 경우를 생각하여 Producer에게 sleep_for 함수를 적용해서 코드의 두 번째 주석을 넣고 실행하니 기존 답에서 모든 수가 4미만으로 나왔습니다.

 

말이 길었습니다.. 질문입니다.

제가 이해한 경우가 맞는지 아니면 멀티쓰레드 쪽의 개념이 포괄적으로 이해해야 될까요? 강사님이 말씀하신대로 뇌가 말랑해지기위해 노력중입니다.

mutex m;
queue<int32> q;

condition_variable cv;

void Producer()
{
	while (true)
	{
		{
			unique_lock<mutex> lock(m);
			
			q.push(100);
		}
		cv.notify_one();

		//cout << q.size() << endl;
                //this_thread::sleep_for(0.001ms);
	}
}

void Consumer()
{
	while (true)
	{
		unique_lock<mutex> lock(m);
		
		cv.wait(lock, []() {return q.empty() == false; });

		int32 data = q.front();
		q.pop();
		cout << q.size() << endl;
	}
}