PoolFiber which supports pausing More...
Public Member Functions | |
ExtendedPoolFiber () | |
ExtendedPoolFiber (IExtendedExecutor executor) | |
void | Pause () |
void | Resume (Action executeFirstAction=null) |
Public Member Functions inherited from ExitGames.Concurrency.Fibers.PoolFiber | |
PoolFiber (IThreadPool pool, IExecutor executor) | |
Construct new instance. More... | |
PoolFiber (IExecutor executor) | |
Create a pool fiber with the default thread pool. More... | |
PoolFiber () | |
Create a pool fiber with the default thread pool and default executor. More... | |
void | Enqueue (Action action) |
Enqueue a single action. More... | |
void | RegisterSubscription (IDisposable toAdd) |
Register subscription to be unsubcribed from when the fiber is disposed. More... | |
bool | DeregisterSubscription (IDisposable toRemove) |
Deregister a subscription. More... | |
IDisposable | Schedule (Action action, long firstInMs) |
IScheduler.Schedule(Action,long) More... | |
IDisposable | ScheduleOnInterval (Action action, long firstInMs, long regularInMs) |
IScheduler.ScheduleOnInterval(Action,long,long) More... | |
void | Start () |
Start consuming actions. More... | |
void | Stop () |
Stop consuming actions. More... | |
void | Dispose () |
Stops the fiber. More... | |
Properties | |
IExtendedExecutor | Executor [get] |
bool | IsPaused [get] |
Properties inherited from ExitGames.Concurrency.Fibers.PoolFiber | |
ICounter | CounterItemsInQueue [get, set] |
ICounter | CounterItemsInExecution [get, set] |
ICounter | CounterEnqueue [get, set] |
ICounter | CounterDequeue [get, set] |
int | NumSubscriptions [get] |
Number of subscriptions. More... | |
Properties inherited from ExitGames.Concurrency.Fibers.IExtendedFiber | |
IExtendedExecutor | Executor [get] |
bool | IsPaused [get] |
Additional Inherited Members | |
Protected Attributes inherited from ExitGames.Concurrency.Fibers.PoolFiber | |
int | started = (int)ExecutionState.Created |
PoolFiber which supports pausing
|
inline |
|
inline |
|
inline |
Implements ExitGames.Concurrency.Fibers.IExtendedFiber.
|
inline |
Implements ExitGames.Concurrency.Fibers.IExtendedFiber.
|
get |
|
get |