dragon.mpbridge

The Dragon MPBridge component maps the Python Multiprocessing API onto Dragon Native components.

Functions

dragon_spawn_main()

Main entrypoint for running a Multiprocessing program backed by Dragon.

dragon_spawn_main()

Main entrypoint for running a Multiprocessing program backed by Dragon. I.e. this is the function first executed when a new Dragon process is started through a Multiprocessing call to process.start(). See dragon.mpbridge.process.Popen._launch.

Modules

connection

Dragon's replacement for the Multiprocessing Connection and Pipe objects

context

Dragon's replacement for the Multiprocessing context object.

heap

Dragon's replacement for the Multiprocessing Heap based on Dragon managed memory.

managers

Dragon's replacement of Multiprocessing Managers.

monkeypatching

A class to monkeypatch Dragon classes into Python Multiprocessing.

pool

Dragon's replacement for Multiprocessing Pool.

process

Dragon's replacement classes for Multiprocessing Process.

queues

Dragon's replacement of Multiprocessing Queue objects based on Channels.

reduction

Dragon's replacements for Multiprocessings 'reduction' module.

shared_memory

Dragon's replacement for Multiprocessing Shared Memory.

sharedctypes

Dragon's replacement for Multiprocessing's shared ctypes objects: Value and Array.

synchronize

Dragon's replacements for the synchronization primitives in Multiprocessing.

util

Dragon's replacement for Multiprocessing's logging methods.