YimMenu/src/fiber_pool.hpp

#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 execute_on_game_thread(std::function<void()> func);

		void fiber_tick();
		static void fiber_func();

		int get_total_fibers();
		int get_used_fibers();

		void reset();

	private:
		std::recursive_mutex m_mutex;
		std::stack<std::function<void()>> m_jobs;
		int m_num_fibers;
	};

	inline fiber_pool* g_fiber_pool{};
}