From f59580dc6c95a4190aaa6bf8e7172ac22b2d7cdb Mon Sep 17 00:00:00 2001 From: Shauren Date: Sat, 8 Oct 2022 20:08:29 +0200 Subject: Core/Threading: Create ThreadPool class (cherry picked from commit d82b2b1a6712df685b989911e3e519809935de03) --- src/common/Threading/ThreadPool.h | 48 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 48 insertions(+) create mode 100644 src/common/Threading/ThreadPool.h (limited to 'src/common/Threading/ThreadPool.h') diff --git a/src/common/Threading/ThreadPool.h b/src/common/Threading/ThreadPool.h new file mode 100644 index 00000000000..1606bf98d1e --- /dev/null +++ b/src/common/Threading/ThreadPool.h @@ -0,0 +1,48 @@ +/* + * This file is part of the TrinityCore Project. See AUTHORS file for Copyright information + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. + * + * This program is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for + * more details. + * + * You should have received a copy of the GNU General Public License along + * with this program. If not, see . + */ + +#ifndef TRINITY_THREAD_POOL_H +#define TRINITY_THREAD_POOL_H + +#include +#include +#include + +namespace Trinity +{ +class ThreadPool +{ +public: + explicit ThreadPool(std::size_t numThreads = std::thread::hardware_concurrency()) : _impl(numThreads) { } + + template + decltype(auto) PostWork(T&& work) + { + return boost::asio::post(_impl, std::forward(work)); + } + + void Join() + { + _impl.join(); + } + +private: + boost::asio::thread_pool _impl; +}; +} + +#endif // TRINITY_THREAD_POOL_H -- cgit v1.2.3