actfw.task package

Submodules

actfw.task.consumer module

class actfw.task.consumer.Consumer

Bases: actfw.task.pipe.Pipe

Consumer Task.

connect(follow)

Raises error

Parameters

follow (Task) – following task

run()

Run and start the activity

actfw.task.isolated module

class actfw.task.isolated.Isolated

Bases: actfw.task.task.Task

A task which has no connection.

actfw.task.pipe module

class actfw.task.pipe.Pipe

Bases: actfw.task.task.Task

Straightforward Pipeline Task.

connect(follow)

Connect following task.

Parameters

follow (Task) – following task

proc(i)

Pipeline Task Processor

Parameters

i – task input

run()

Run and start the activity

stop()

Stop the activity

actfw.task.producer module

class actfw.task.producer.Producer

Bases: actfw.task.pipe.Pipe

Producer Task.

actfw.task.task module

class actfw.task.task.Task

Bases: threading.Thread

Actcast Application Task

Module contents