Changeset View

Standalone View

Show First 20 Lines • Show All 58 Lines • ▼ Show 20 Lines	public:
* @return the number of threaded workers.		* @return the number of threaded workers.
*/		*/
size_t GetNumberOfWorkers() const;		size_t GetNumberOfWorkers() const;

/**		/**
* Push a task to be executed.		* Push a task to be executed.
*/		*/
template<typename T>		template<typename T>
Future<std::invoke_result_t<T>> PushTask(T&& func, TaskPriority priority = TaskPriority::NORMAL)		Future<T> PushTask(T func, TaskPriority priority = TaskPriority::NORMAL)
{		{
Future<std::invoke_result_t<T>> ret;		static_assert(std::is_invocable_v<T>);
DoPushTask(ret.Wrap(std::move(func)), priority);		Future<T> ret(std::move(func));;
		DoPushTask(ret.GetTask(), priority);
return ret;		return ret;
}		}

private:		private:
TaskManager(size_t numberOfWorkers);		TaskManager(size_t numberOfWorkers);

void DoPushTask(std::function<void()>&& task, TaskPriority priority);		void DoPushTask(PackagedTask task, TaskPriority priority);

class Impl;		class Impl;
std::unique_ptr<Impl> m;		std::unique_ptr<Impl> m;
};		};
} // namespace Threading		} // namespace Threading

#endif // INCLUDED_THREADING_TASKMANAGER		#endif // INCLUDED_THREADING_TASKMANAGER