Module brine.queues
Queue subclasses supporting automatic brining or barreling of
values as they are passed along.
These facilitate the sending of callable code between processes for
parallel execution.
It can conceivably be used to send callable code between machines as
well (eg: via a network socket). Utmost care must be taken to ensure
the transport medium is used securely, to prevent an intruder from
executing arbitrary code on the host.
Brine Queues
-
class brine.queues.BrinedQueue(maxsize=0)[source]
Bases: brine.queues.BrinedQueueMix, multiprocessing.queues.Queue
A Queue that takes the additional step of calling brine on its
put argumens, and unbrine on its get results.
-
class brine.queues.BrinedJoinableQueue(maxsize=0)[source]
Bases: brine.queues.BrinedQueueMix, multiprocessing.queues.JoinableQueue
A JoinableQueue that takes the additional step of calling
brine on its put argumens, and unbrine on its get results.
-
class brine.queues.BrinedSimpleQueue[source]
Bases: multiprocessing.queues.SimpleQueue
A SimpleQueue that takes the additional step of calling brine
on its put argumens, and unbrine on its get results.
Barrel Queues
-
class brine.queues.BarreledQueue(maxsize=0)[source]
Bases: brine.queues.BarreledQueueMix, multiprocessing.queues.Queue
A Queue that takes the additional step of packing its put
argument into a Barrel and unpacking its get results from a
Barrel
-
class brine.queues.BarreledJoinableQueue(maxsize=0)[source]
Bases: brine.queues.BarreledQueueMix, multiprocessing.queues.JoinableQueue
A JoinableQueue that takes the additional step of packing its
put argument into a Barrel and unpacking its get results
from a Barrel
-
class brine.queues.BarreledSimpleQueue[source]
Bases: multiprocessing.queues.SimpleQueue
A SimpleQueue that packs data into a Barrel before sending
with the put method, and unpacks data from a Barrel before
returning from the get method.