Changeset View

Standalone View

Show First 20 Lines • Show All 61 Lines • ▼ Show 20 Lines	public:

/**		/**
* 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<std::invoke_result_t<T>> PushTask(T&& func, TaskPriority priority = TaskPriority::NORMAL)
{		{
Future<std::invoke_result_t<T>> ret;		Future<std::invoke_result_t<T>> ret;
DoPushTask(ret.Wrap(std::move(func)), priority);		DoPushTask(ret.Wrap(std::forward<T>(func)), 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