WorkQueueBase class abstract
Base class for work queues that manage asynchronous task execution with support for nested task scheduling without deadlocks.
- Implementers
Constructors
- WorkQueueBase.new(CollectionFactoryCallback queueFactory)
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- isProcessing → bool
-
Returns true if the queue is currently processing tasks
no setter
- queueFactory → CollectionFactoryCallback
-
Factory for creating new task queues
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- tasksPending → int
-
Returns the number of pending tasks in the main queue
no setter
Methods
-
clear(
) → Future< void> - Clears all pending tasks and waits for current tasks to complete
-
enqueue<
R> (TaskBase< R> task) → Future<R> - Enqueues a task either in the current scope or main queue
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
processNextTask(
) → void - Processes the next task in the queue or current scope
-
schedule<
R> (RunnableCallback< R> callback) → Future<R> - Schedules a new task for execution
-
scheduleTask(
) → void - Starts processing tasks if not already processing
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited