52 lines
2.3 KiB
C
52 lines
2.3 KiB
C
|
#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(); }
|