IScheduler Struct Reference

A thread-pool scheduler that supports scheduling one-off functions as well as dependency graphs. More...

Inheritance diagram for IScheduler:

Collaboration diagram for IScheduler:

Detailed Description

A thread-pool scheduler that supports scheduling one-off functions as well as dependency graphs.

Public Member Functions
virtual ErrCode INTERFACE_FUNC	scheduleFunction (IFunction *function, IAwaitable **awaitable)=0
	Schedules the specified work function to run on the thread-pool. The call does not block but immediately returns an awaitable that represents the asynchronous execution. It can be waited upon and queried for status and result. More...
virtual ErrCode INTERFACE_FUNC	scheduleWork (IWork *work)=0
	Schedules the specified work callback to run on the thread-pool. The call does not block. More...
virtual ErrCode INTERFACE_FUNC	scheduleGraph (ITaskGraph *graph, IAwaitable **awaitable)=0
	Schedules the specified dependency graph to run on the thread-pool. The call does not block but immediately returns an awaitable that represents the asynchronous execution. It can be waited upon and queried for status and result. Any exceptions that occur during the graph execution are silently ignored. More...
virtual ErrCode INTERFACE_FUNC	stop ()=0
	Cancels all outstanding work and waits for the remaining to complete. After this point the scheduler does not allow any new work or graphs for scheduling.
virtual ErrCode INTERFACE_FUNC	waitAll ()=0
	Waits fo all current scheduled work and tasks to complete.
virtual ErrCode INTERFACE_FUNC	isMultiThreaded (Bool *multiThreaded)=0
	Returns whether more than one worker thread is used. More...
Public Member Functions inherited from IBaseObject
virtual ErrCode INTERFACE_FUNC	borrowInterface (const IntfID &intfID, void **obj) const =0
	Returns another interface which is supported by the object without incrementing the reference count. More...
virtual ErrCode INTERFACE_FUNC	dispose ()=0
	Disposes all references held by the object. More...
virtual ErrCode INTERFACE_FUNC	getHashCode (SizeT *hashCode)=0
	Returns hash code of the object. More...
virtual ErrCode INTERFACE_FUNC	equals (IBaseObject *other, Bool *equal) const =0
	Compares object to another object for equality. More...
virtual ErrCode INTERFACE_FUNC	toString (CharPtr *str)=0
	Returns a string representation of the object. More...
Public Member Functions inherited from IUnknown
virtual ErrCode INTERFACE_FUNC	queryInterface (const IntfID &intfID, void **obj)=0
	Returns another interface which is supported by the object and increments the reference count. More...
virtual int INTERFACE_FUNC	addRef ()=0
	Increments the reference count for an interface on an object. More...
virtual int INTERFACE_FUNC	releaseRef ()=0
	Decrements the reference count for an interface on an object. More...

Member Function Documentation

isMultiThreaded()

virtual ErrCode INTERFACE_FUNC isMultiThreaded ( Bool *  multiThreaded )

pure virtual

Returns whether more than one worker thread is used.

Parameters

[out]

multiThreaded

Returns true if more that one worker thread is used by the scheduler.

scheduleFunction()

virtual ErrCode INTERFACE_FUNC scheduleFunction ( IFunction *  function, IAwaitable **  awaitable  )

pure virtual

Schedules the specified work function to run on the thread-pool. The call does not block but immediately returns an awaitable that represents the asynchronous execution. It can be waited upon and queried for status and result.

Parameters

	function	The function to schedule for execution.
[out]	awaitable	The object representing the state and result of the execution.

Return values

OPENDAQ_ERR_SCHEDULER_STOPPED

when the scheduler already stopped and is not accepting any more work.

scheduleGraph()

virtual ErrCode INTERFACE_FUNC scheduleGraph ( ITaskGraph *  graph, IAwaitable **  awaitable  )

pure virtual

Schedules the specified dependency graph to run on the thread-pool. The call does not block but immediately returns an awaitable that represents the asynchronous execution. It can be waited upon and queried for status and result. Any exceptions that occur during the graph execution are silently ignored.

Parameters

	graph	The dependency graph (acyclic directed graph) to schedule.
[out]	awaitable	The object representing the state and result of the execution.

Return values

OPENDAQ_ERR_SCHEDULER_STOPPED

when the scheduler already stopped and is not accepting any more work.

scheduleWork()

virtual ErrCode INTERFACE_FUNC scheduleWork ( IWork *  work )

pure virtual

Schedules the specified work callback to run on the thread-pool. The call does not block.

Parameters

work	The function to schedule for execution.

Return values

OPENDAQ_ERR_SCHEDULER_STOPPED

when the scheduler already stopped and is not accepting any more work.

Work is a lightweight callback that returns no value and accepts no procedure. It has less overhead than function. The function does not return awaitable object.