actfw_core.task package¶

Submodules¶

actfw_core.task.consumer module¶

class actfw_core.task.consumer.Consumer¶

Bases: Generic[actfw_core.task.consumer.T_IN], actfw_core.task.task.Task, actfw_core.task.consumer._ConsumerMixin[actfw_core.task.consumer.T_IN]

Consumer Task.

proc(i: actfw_core.task.consumer.T_IN) → None¶

Pipeline Task Processor

Parameters: i – task input

run() → None¶: Run and start the activity

actfw_core.task.isolated module¶

class actfw_core.task.isolated.Isolated¶

Bases: actfw_core.task.task.Task

A task which has no connection.

actfw_core.task.join module¶

class actfw_core.task.join.Join¶

Bases: actfw_core.task.task.Task, actfw_core.task.producer._ProducerMixin[Tuple[Any, …]], actfw_core.task.consumer._ConsumerMixin[Any]

Join Task.

run() → None¶: Run and start the activity

actfw_core.task.pipe module¶

class actfw_core.task.pipe.Pipe¶

Bases: Generic[actfw_core.task.pipe.T_OUT, actfw_core.task.pipe.T_IN], actfw_core.task.task.Task, actfw_core.task.producer._ProducerMixin[actfw_core.task.pipe.T_OUT], actfw_core.task.consumer._ConsumerMixin[actfw_core.task.pipe.T_IN]

Straightforward Pipeline Task.

proc(i: actfw_core.task.pipe.T_IN) → actfw_core.task.pipe.T_OUT¶: Pipeline Task Processor

run() → None¶: Run and start the activity

actfw_core.task.producer module¶

class actfw_core.task.producer.Producer¶

Bases: Generic[actfw_core.task.producer.T_OUT], actfw_core.task.task.Task, actfw_core.task.producer._ProducerMixin[actfw_core.task.producer.T_OUT]

Producer Task.

proc() → actfw_core.task.producer.T_OUT¶: Pipeline Task Processor

run() → None¶: Run and start the activity

actfw_core.task.task module¶

class actfw_core.task.task.Task¶

Bases: threading.Thread, actfw_core.task.task._TaskI

run() → None¶: Run and start the activity

running: bool¶: Actcast Application Task

stop() → None¶: Stop the activity

actfw_core.task.tee module¶

class actfw_core.task.tee.Tee¶

Bases: Generic[actfw_core.task.tee.T], actfw_core.task.task.Task, actfw_core.task.producer._ProducerMixin[actfw_core.task.tee.T], actfw_core.task.consumer._ConsumerMixin[actfw_core.task.tee.T]

Tee Task.

run() → None¶: Run and start the activity