pypushflow.concurrent.non_daemonic.SpawnNonDaemonicContext

class pypushflow.concurrent.non_daemonic.SpawnNonDaemonicContext

Bases: SpawnContext

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 SpawnNonDaemonicProcess

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)