Chris@102: //  thread_pool.hpp  --------------------------------------------------------------//
Chris@102: 
Chris@102: //  Copyright 2013 Andrey Semashev
Chris@102: 
Chris@102: //  Distributed under the Boost Software License, Version 1.0.
Chris@102: //  See http://www.boost.org/LICENSE_1_0.txt
Chris@102: 
Chris@102: 
Chris@102: #ifndef BOOST_DETAIL_WINAPI_THREAD_POOL_HPP
Chris@102: #define BOOST_DETAIL_WINAPI_THREAD_POOL_HPP
Chris@102: 
Chris@102: #include <boost/detail/winapi/basic_types.hpp>
Chris@102: 
Chris@102: #ifdef BOOST_HAS_PRAGMA_ONCE
Chris@102: #pragma once
Chris@102: #endif
Chris@102: 
Chris@102: #if BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN2K
Chris@102: 
Chris@102: namespace boost
Chris@102: {
Chris@102: namespace detail
Chris@102: {
Chris@102: namespace winapi
Chris@102: {
Chris@102: #if defined( BOOST_USE_WINDOWS_H )
Chris@102: 
Chris@102: typedef ::WAITORTIMERCALLBACKFUNC WAITORTIMERCALLBACKFUNC_;
Chris@102: typedef ::WAITORTIMERCALLBACK WAITORTIMERCALLBACK_;
Chris@102: 
Chris@102: using ::RegisterWaitForSingleObject;
Chris@102: using ::UnregisterWait;
Chris@102: using ::UnregisterWaitEx;
Chris@102: 
Chris@102: const ULONG_ wt_execute_default = WT_EXECUTEDEFAULT;
Chris@102: const ULONG_ wt_execute_in_io_thread = WT_EXECUTEINIOTHREAD;
Chris@102: const ULONG_ wt_execute_in_ui_thread = WT_EXECUTEINUITHREAD;
Chris@102: const ULONG_ wt_execute_in_wait_thread = WT_EXECUTEINWAITTHREAD;
Chris@102: const ULONG_ wt_execute_only_once = WT_EXECUTEONLYONCE;
Chris@102: const ULONG_ wt_execute_in_timer_thread = WT_EXECUTEINTIMERTHREAD;
Chris@102: const ULONG_ wt_execute_long_function = WT_EXECUTELONGFUNCTION;
Chris@102: const ULONG_ wt_execute_in_persistent_io_thread = WT_EXECUTEINPERSISTENTIOTHREAD;
Chris@102: const ULONG_ wt_execute_in_persistent_thread = WT_EXECUTEINPERSISTENTTHREAD;
Chris@102: const ULONG_ wt_transfer_impersonation = WT_TRANSFER_IMPERSONATION;
Chris@102: 
Chris@102: inline ULONG_ wt_set_max_threadpool_threads(ULONG_ flags, ULONG_ limit)
Chris@102: {
Chris@102:     return WT_SET_MAX_THREADPOOL_THREADS(flags, limit);
Chris@102: }
Chris@102: 
Chris@102: #else
Chris@102: 
Chris@102: extern "C" {
Chris@102: 
Chris@102: typedef void (NTAPI* WAITORTIMERCALLBACKFUNC_) (PVOID_, BOOLEAN_);
Chris@102: typedef WAITORTIMERCALLBACKFUNC_ WAITORTIMERCALLBACK_;
Chris@102: 
Chris@102: __declspec(dllimport) BOOL_ WINAPI RegisterWaitForSingleObject
Chris@102: (
Chris@102:     HANDLE_* phNewWaitObject,
Chris@102:     HANDLE_ hObject,
Chris@102:     WAITORTIMERCALLBACK_ Callback,
Chris@102:     PVOID_ Context,
Chris@102:     ULONG_ dwMilliseconds,
Chris@102:     ULONG_ dwFlags
Chris@102: );
Chris@102: 
Chris@102: __declspec(dllimport) BOOL_ WINAPI UnregisterWait(HANDLE_ WaitHandle);
Chris@102: __declspec(dllimport) BOOL_ WINAPI UnregisterWaitEx(HANDLE_ WaitHandle, HANDLE_ CompletionEvent);
Chris@102: 
Chris@102: } // extern "C"
Chris@102: 
Chris@102: const ULONG_ wt_execute_default = 0x00000000;
Chris@102: const ULONG_ wt_execute_in_io_thread = 0x00000001;
Chris@102: const ULONG_ wt_execute_in_ui_thread = 0x00000002;
Chris@102: const ULONG_ wt_execute_in_wait_thread = 0x00000004;
Chris@102: const ULONG_ wt_execute_only_once = 0x00000008;
Chris@102: const ULONG_ wt_execute_in_timer_thread = 0x00000020;
Chris@102: const ULONG_ wt_execute_long_function = 0x00000010;
Chris@102: const ULONG_ wt_execute_in_persistent_io_thread = 0x00000040;
Chris@102: const ULONG_ wt_execute_in_persistent_thread = 0x00000080;
Chris@102: const ULONG_ wt_transfer_impersonation = 0x00000100;
Chris@102: 
Chris@102: inline ULONG_ wt_set_max_threadpool_threads(ULONG_ flags, ULONG_ limit)
Chris@102: {
Chris@102:     return flags | (limit << 16);
Chris@102: }
Chris@102: 
Chris@102: #endif
Chris@102: }
Chris@102: }
Chris@102: }
Chris@102: 
Chris@102: #endif // BOOST_USE_WINAPI_VERSION >= BOOST_WINAPI_VERSION_WIN2K
Chris@102: 
Chris@102: #endif // BOOST_DETAIL_WINAPI_THREAD_POOL_HPP