2019-03-21 20:18:31 +01:00
|
|
|
#pragma once
|
|
|
|
#include "common.hpp"
|
|
|
|
|
|
|
|
namespace big
|
|
|
|
{
|
|
|
|
class fiber_pool
|
|
|
|
{
|
|
|
|
public:
|
|
|
|
explicit fiber_pool(std::size_t num_fibers);
|
|
|
|
~fiber_pool();
|
|
|
|
|
|
|
|
void queue_job(std::function<void()> func);
|
|
|
|
|
|
|
|
void fiber_tick();
|
|
|
|
static void fiber_func();
|
2023-03-01 21:27:15 +00:00
|
|
|
|
2023-03-09 12:23:01 +00:00
|
|
|
int get_total_fibers();
|
|
|
|
int get_used_fibers();
|
|
|
|
|
|
|
|
void reset();
|
|
|
|
|
2019-03-21 20:18:31 +01:00
|
|
|
private:
|
|
|
|
std::recursive_mutex m_mutex;
|
|
|
|
std::stack<std::function<void()>> m_jobs;
|
2023-03-09 12:23:01 +00:00
|
|
|
int m_num_fibers;
|
2019-03-21 20:18:31 +01:00
|
|
|
};
|
|
|
|
|
2023-03-01 21:27:15 +00:00
|
|
|
inline fiber_pool* g_fiber_pool{};
|
2019-03-21 20:18:31 +01:00
|
|
|
}
|