#pragma once
#include "ThirdPartyHeadersBegin.h"
#if defined _WIN32
#include <windows.h>
#else
#include <pthread.h>
#if defined __APPLE__
#include <sys/types.h>
#include <sys/sysctl.h>
#endif
#endif
#include "ThirdPartyHeadersEnd.h"
#include "MASTER.h"
#include "GLOBAL.h"
#include "Mutex_s.h"
#if defined _WIN32
typedef HANDLE pthread_t;
#endif
struct ___2122
{
	___2664 ___2494;
	std::vector<pthread_t> ___2648;
	static int ___2827();
	___2122() { ___2494 = new ___2665(); }
	~___2122() { delete ___2494; }
	struct ThreadJobData
	{
		___4160 m_job;
		___90 m_jobData;
		ThreadJobData(___4160 ___2118, ___90 ___2123) : m_job(___2118), m_jobData(___2123) {}
	};
#if defined _WIN32
	static DWORD WINAPI ___4162(LPVOID data);
#else
	static void *___4162(void *data);
#endif
	void addJob(___4160 ___2118, ___90 ___2123);
	void wait();
	void lock() { ___2494->lock(); }
	void unlock() { ___2494->unlock(); }
};
inline int ___2122::___2827()
{
	int ___2828 = 0;
#if defined _WIN32
	SYSTEM_INFO sysinfo;
	GetSystemInfo(&sysinfo);
	___2828 = static_cast<int>(sysinfo.dwNumberOfProcessors);
#elif defined __APPLE__
	int nm[2];
	size_t len = 4;
	uint32_t count;
	nm[0] = CTL_HW;
	nm[1] = HW_AVAILCPU;
	sysctl(nm, 2, &count, &len, NULL, 0);
	if (count < 1)
	{
		nm[1] = HW_NCPU;
		sysctl(nm, 2, &count, &len, NULL, 0);
		if (count < 1)
			count = 1;
	}
	___2828 = static_cast<int>(count);
#else
	___2828 = static_cast<int>(sysconf(_SC_NPROCESSORS_ONLN));
#endif
	return ___2828;
}
#if defined _WIN32
inline DWORD WINAPI ___2122::___4162(LPVOID data)
#else
inline void *___2122::___4162(void *data)
#endif
{
	ThreadJobData *___2123 = reinterpret_cast<ThreadJobData *>(data);
	___2123->m_job(___2123->m_jobData);
	delete ___2123;
	return NULL;
}
inline void ___2122::addJob(___4160 ___2118, ___90 ___2123)
{
	lock();
	___2122::ThreadJobData *threadJobData = new ThreadJobData(___2118, ___2123);
#if defined _WIN32
	___2648.push_back(CreateThread(NULL, 0, ___4162, threadJobData, 0, NULL));
#else
	pthread_t thread;
	pthread_create(&thread, NULL, ___4162, (void *)threadJobData);
	___2648.push_back(thread);
#endif
	unlock();
}
inline void ___2122::wait()
{
	size_t i;
	for (i = 0; i < ___2648.size(); ++i)
	{
		lock();
		pthread_t thr = ___2648[i];
		unlock();
#if defined _WIN32
		WaitForSingleObject(thr, INFINITE);
#else
		pthread_join(thr, NULL);
#endif
	}
	lock();
	___2648.erase(___2648.begin(), ___2648.begin() + i);
	unlock();
}