processes

Module Contents

Classes

PassSigFeedback
ProcessProgressCmd	Enum where members are also (and must be) ints
ProcessProgressTask
ProcessProgFeedback
ProgressTracker
ProcessProgress
ProcessTask
ProcessSigPassTask
ProcessTaskResult
SingleProcess	Process objects represent activity that is run in a separate process

Functions

AutoProxy(*args[, incref, manager_owned])
apply_autoproxy_fix()
create_manager(→ multiprocessing.Manager)
create_queue(→ multiprocessing.JoinableQueue)
get_empty_queue_exception(→ type)
get_max_num_processes(→ int)
locate_uuid(object_list, wanted_uuid)
prog_sig_pass(signals, cmd, args)

Attributes

logger
orig_AutoProxy

processes.logger = "'processes'"

processes.orig_AutoProxy

processes.AutoProxy(*args, incref=True, manager_owned=False, **kwargs)

processes.apply_autoproxy_fix()

processes.create_manager() → multiprocessing.Manager

processes.create_queue() → multiprocessing.JoinableQueue

processes.get_empty_queue_exception() → type

processes.get_max_num_processes() → int

processes.locate_uuid(object_list: List[object], wanted_uuid: uuid.UUID)

class processes.PassSigFeedback(feedback_queue: multiprocessing.JoinableQueue)

fbq

add_particlenode(node: tree_model.DatasetTreeNode, num: int)

add_all_particlenodes(all_nodes: list)

add_datasetnode(node: tree_model.DatasetTreeNode)

reset_tree()

bin_size(bin_size: int)

set_start(start: float)

set_tmin(tmin: float)

data_loaded()

add_irf(decay: numpy.ndarray, time_series: numpy.ndarray)

class processes.ProcessProgressCmd

Bases: enum.IntEnum

Enum where members are also (and must be) ints

Start

SetMax

AddMax

Single

Step

SetValue

Complete

SetStatus

class processes.ProcessProgressTask(task_cmd: ProcessProgressCmd, args=None)

task_cmd

args = 'None'

class processes.ProcessProgFeedback(feedback_queue: multiprocessing.JoinableQueue)

fbq

set_max(max_value: int)

add_max(max_to_add: int)

single()

step(value: float = None)

set_value(value: int)

end()

set_status(status)

start(max_value: int = None)

processes.prog_sig_pass(signals: signals.ProcessThreadSignals, cmd: ProcessProgressCmd, args)

class processes.ProgressTracker(num_iterations: int = None, num_trackers: int = 1)

property num_iterations: int

property num_trackers: int

has_num_iterations = 'False'

_num_iterations = 'None'

_num_trackers = 'None'

_step_value = 'None'

_current_value = '0.0'

calc_step_value()

iterate() → int

strict_iterate() → float

reset()

class processes.ProcessProgress(prog_fb: ProcessProgFeedback, num_iterations: int = None, num_of_processes: int = 1)

Bases: ProgressTracker

_prog_fb

_accum_step

start_progress()

iterate()

class processes.ProcessTask(obj: object, method_name: str, args=None)

uuid

obj

method_name

args = 'None'

class processes.ProcessSigPassTask(sig_pass_type: signals.WorkerSigPassType, sig_args=None)

sig_pass_type

sig_args = 'None'

class processes.ProcessTaskResult(task_uuid: uuid.UUID = None, task_return=None, new_task_obj: ProcessTask = None, task_complete: bool = True, dont_send: bool = False)

task_uuid = 'None'

task_return = 'None'

new_task_obj = 'None'

task_complete = 'True'

dont_send = 'False'

class processes.SingleProcess(task_queue: multiprocessing.JoinableQueue, result_queue: multiprocessing.JoinableQueue, feedback_queue: multiprocessing.JoinableQueue = None, temp_dir: tempfile.TemporaryDirectory = None)

Bases: multiprocessing.Process

Process objects represent activity that is run in a separate process

The class is analogous to threading.Thread

task_queue

result_queue

feedback_queue = 'None'

_temp_dir = 'None'

run()

Method to be run in sub-process; can be overridden in sub-class