WinThreadPoolWrapper is a simple wrapper class for windows thread pool apis, such as CreateThreadpool().
Using by this, we don't need to know detaily those windows thread pool apis.
This project is written in VS2010.
First, you should write your own work thread.
For example, below code is work thread which prints odd numbers between min and max number.
Let's say this function's name is MyWorkCallback().
VOID CALLBACK MyWorkCallback(PTP_CALLBACK_INSTANCE instance, PVOID parameter, PTP_WORK work)
{
if(parameter == nullptr) { return; }
ParamInfo* param_info = static_cast<ParamInfo*>(parameter);
for(int i = param_info->min_number_; i < param_info->max_number_; i++)
{
if((i % 2) == 1)
{
AcquireSRWLockExclusive(&g_lock);
cout << "[thread id = " << GetCurrentThreadId() << "] find number = " << i << endl;
g_found_count++;
cout << "[found count = " << g_found_count << "]" << endl;
ReleaseSRWLockExclusive(&g_lock);
}
Sleep(100);
}
return;
}And then, we simply use above function using by ThreadPoolWrapper.
Like this, in your main,
int main(int argc, char* argv[])
{
//Init SRWLOCK object
InitializeSRWLock(&g_lock);
//Init ThreadPoolWrapper
ThreadPoolWrapper wrapper;
wrapper.Init();
//Set Min/Max Thread Count
wrapper.SetThreadCount(1, 3);
//put callback with pram into the Threadpool
ParamInfo infos[] = {ParamInfo(1, 50), ParamInfo(51, 100)};
for_each(std::begin(infos), std::end(infos), [&](ParamInfo& info)
{
wrapper.SetCallback(MyWorkCallback, static_cast<PVOID>(&info));
});
//Wait for Callback finish
wrapper.WaitCallbackFinish();
getchar();
return 0;
}- http://msdn.microsoft.com/en-us/library/windows/desktop/ms686980(v=vs.85).aspx
- http://blogs.msdn.com/b/harip/archive/2010/10/11/introduction-to-the-windows-threadpool-part-1.aspx
- Windows via C/C++(5th edition) by Jeffrey Richter
- mail : nnhope@hotmail.com
- stackoverflow : http://stackoverflow.com/users/2231098/codedreamer