WorkerRunner[Input: Any #send, Output: Any #send]¶

[Source]

WorkerRunner is responsible for delivering data to Worker instances for processing and for coordinating the job lifecycle with other fork_join library actors.

actor tag WorkerRunner[Input: Any #send, Output: Any #send]

Constructors¶

create¶

[Source]

new tag create(
  coordinator: _Coordinator[Input, Output] tag,
  collector: CollectorRunner[Input, Output] tag,
  notify: Worker[Input, Output] iso)
: WorkerRunner[Input, Output] tag^

Parameters¶

coordinator: _Coordinator[Input, Output] tag
collector: CollectorRunner[Input, Output] tag
notify: Worker[Input, Output] iso

Returns¶

WorkerRunner[Input, Output] tag^

Public Functions¶

deliver¶

[Source]

Called to send a result to the collector and request additional work from the coordinator.

fun ref deliver(
  result: Output)
: None val

Parameters¶

result: Output

Returns¶

None val

yield¶

[Source]

Called to have the worker yield the CPU and continue later.

fun ref yield()
: None val

Returns¶

None val