WorkerPool class

A worker pool for dispatching tasks to local worker threads.

Constructors

WorkerPool.new()
Construct a new pool.

Properties

hashCode → int
The hash code for this object.
no setterinherited
localIsolates → List<Isolate>
Managed isolates
final
nextWorker ↔ int
Next worker that a task will be dispatched to.
getter/setter pair
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
workers → List<WorkerHandle>
Available workers.
final

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
run(WorkerMessage msg) → Future<WorkerResponse>
Process a WorkerMessage on the pool.
startLocalWorker() → Future<WorkerHandle>
Start a new local worker.
startLocalWorkers(int count) → Future<List<WorkerHandle>>
Convenience function. See startLocalWorker
stopLocalWorkers() → Future<void>
Stop all local workers.
toString() → String
A string representation of this object.
inherited
transform(Stream<List<Conversation>> data, List<StepDescriptor> steps, PackedDataCache? cache) → Stream<List<Conversation>>
Dispatch the stream to local workers and transform using the provided steps

Operators

operator ==(Object other) → bool
The equality operator.
inherited