pypushflow.concurrent.non_daemonic.ForkNonDaemonicContext#

class pypushflow.concurrent.non_daemonic.ForkNonDaemonicContext[source]#

Bases: ForkContext

Array(typecode_or_type, size_or_initializer, *, lock=True)#: Returns a synchronized shared array

exception AuthenticationError#

Bases: ProcessError

args#

with_traceback()#: Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

Barrier(parties, action=None, timeout=None)#: Returns a barrier object

BoundedSemaphore(value=1)#: Returns a bounded semaphore object

exception BufferTooShort#

Bases: ProcessError

args#

with_traceback()#: Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

Condition(lock=None)#: Returns a condition object

Event()#: Returns an event object

JoinableQueue(maxsize=0)#: Returns a queue object

Lock()#: Returns a non-recursive lock object

Manager()#

Returns a manager associated with a running server process

The managers methods such as Lock(), Condition() and Queue() can be used to create shared objects.

Pipe(duplex=True)#: Returns two connection object connected by a pipe

Pool(processes=None, initializer=None, initargs=(), maxtasksperchild=None)#: Returns a process pool object

Process#: alias of ForkNonDaemonicProcess

exception ProcessError#

Bases: Exception

args#

with_traceback()#: Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

Queue(maxsize=0)#: Returns a queue object

RLock()#: Returns a recursive lock object

RawArray(typecode_or_type, size_or_initializer)#: Returns a shared array

RawValue(typecode_or_type, *args)#: Returns a shared object

Semaphore(value=1)#: Returns a semaphore object

SimpleQueue()#: Returns a queue object

exception TimeoutError#

Bases: ProcessError

args#

with_traceback()#: Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

Value(typecode_or_type, *args, lock=True)#: Returns a synchronized shared object

static active_children()#: Return list of process objects corresponding to live child processes

allow_connection_pickling()#: Install support for sending connections and sockets between processes

cpu_count()#: Returns the number of CPUs in the system

static current_process()#: Return process object representing the current process

freeze_support()#: Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit.

get_context(method=None)#

get_logger()#: Return package logger – if it does not already exist then it is created.

get_start_method(allow_none=False)#

log_to_stderr(level=None)#: Turn on logging and add a handler which prints to stderr

static parent_process()#: Return process object representing the parent process

property reducer#: Controls how objects will be reduced to a form that can be shared with other processes.

set_executable(executable)#: Sets the path to a python.exe or pythonw.exe binary used to run child processes instead of sys.executable when using the ‘spawn’ start method. Useful for people embedding Python.

set_forkserver_preload(module_names)#: Set list of module names to try to load in forkserver process. This is really just a hint.

set_start_method(method, force=False)#