multiprocessor Module

Functions

log_listener_process

log_listener_process(queue)

Parameters

queue

monitor_exception

monitor_exception(exception_queue, process_ids)

Parameters

exception_queue
process_ids

multi_processor_change_acl

multi_processor_change_acl(adl, path=None, method_name='', acl_spec='', number_of_sub_process=None)

Parameters

adl
path
default value: None
method_name
acl_spec
number_of_sub_process
default value: None

processor

processor(adl, file_path_queue, finish_queue_processing_flag, method_name, acl_spec, log_queue, exception_queue)

Parameters

adl
file_path_queue
finish_queue_processing_flag
method_name
acl_spec
log_queue
exception_queue