blob: 4ed81d7a26c7c18c4de66cc90aa606470a1e14c2 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
// Copyright Epic Games, Inc. All Rights Reserved.
#include "iothreadpool.h"
namespace zen {
WinIoThreadPool::WinIoThreadPool(int InThreadCount)
{
// Thread pool setup
m_ThreadPool = CreateThreadpool(NULL);
SetThreadpoolThreadMinimum(m_ThreadPool, InThreadCount);
SetThreadpoolThreadMaximum(m_ThreadPool, InThreadCount * 2);
InitializeThreadpoolEnvironment(&m_CallbackEnvironment);
m_CleanupGroup = CreateThreadpoolCleanupGroup();
SetThreadpoolCallbackPool(&m_CallbackEnvironment, m_ThreadPool);
SetThreadpoolCallbackCleanupGroup(&m_CallbackEnvironment, m_CleanupGroup, NULL);
}
WinIoThreadPool::~WinIoThreadPool()
{
CloseThreadpool(m_ThreadPool);
}
void
WinIoThreadPool::CreateIocp(HANDLE IoHandle, PTP_WIN32_IO_CALLBACK Callback, void* Context)
{
m_ThreadPoolIo = CreateThreadpoolIo(IoHandle, Callback, Context, &m_CallbackEnvironment);
}
} // namespace zen
|