#include "PCH.h"
#include "ThreadSyncManager.h"

#include "Logger.h"

#include <algorithm>
#include <string>

namespace sh::core
{
	void ThreadSyncManager::PushSyncable(ISyncable& syncable)
	{
		syncables.push(&syncable);
	}

	void ThreadSyncManager::AddThread(EngineThread& thread)
	{
		auto it = std::find(threads.begin(), threads.end(), &thread);
		if (it != threads.end()) // 중복 확인
			return;

		threads.push_back(&thread);
	}

	void ThreadSyncManager::Sync()
	{
		//SH_INFO("Start sync");
		for (int i = 0; i < threads.size(); ++i)
			threads[i]->mutex.lock(); // 자고 있는 상태면 잠금을 획득 할 수 있다. 아니면 대기

		while (!syncables.empty())
		{
			core::ISyncable* syncable = syncables.front();
			syncables.pop();

			if (syncable)
				syncable->Sync();
		}

		for (int i = threads.size() - 1; i >= 0; --i)
			threads[i]->mutex.unlock();
	}

	void ThreadSyncManager::AwakeThread()
	{
		for (auto& thr : threads)
			thr->Awake();
	}
}//namespace