|
Undefined
|
|
AcknowledgementError
|
|
Channel
A communications channel.
|
|
PersistentChannel
A persistent communications channel which can handle peer disconnection,
acting as a server, meaning that this channel is associated with a specific
address which can be contacted by other processes.
|
|
Exchange
A communications exchange that can be used to detect channels which are
ready to communicate.
|
|
Persistent
A mix-in class providing methods to exchanges for the management of
persistent communications.
|
|
ManagedCallable
A callable managed by an exchange.
|
|
PersistentCallable
A callable which sets up a persistent communications channel.
|
|
BackgroundCallable
A callable which sets up a persistent communications channel, but is
unmanaged by an exchange.
|
|
Map
An exchange which can be used like the built-in 'map' function.
|
|
Queue
An exchange acting as a queue, making data from created processes available
in the order in which it is received.
|
|
MakeParallel
A wrapper around functions making them able to communicate results.
|
|
MakeReusable
A wrapper around functions making them able to communicate results in a
reusable fashion.
|
|
PersistentExchange
An exchange which manages persistent communications.
|
|
PersistentQueue
A queue which manages persistent communications.
|
|
BackgroundQueue(address)
Connect to a process reachable via the given 'address', making the results
of which accessible via a queue. |
source code
|
|
|
pmap(callable,
sequence,
limit=None)
A parallel version of the built-in map function with an optional process
'limit'. |
source code
|
|
|
|
|
_get_number_of_cores_solaris()
Return the number of cores for OpenSolaris 2008.05 and possibly other
editions of Solaris. |
source code
|
|
|
create_socketpair()
Create a new process, returning a communications channel to both the
creating process and the created process. |
source code
|
|
|
create_pipes()
Create a new process, returning a communications channel to both the
creating process and the created process. |
source code
|
|
|
create()
Create a new process, returning a communications channel to both the
creating process and the created process. |
source code
|
|
|
|
|
create_persistent(address)
Create a new process, returning a persistent communications channel between
the creating process and the created process. |
source code
|
|
|
connect_persistent(address)
Connect via a persistent channel to an existing created process, reachable
at the given 'address'. |
source code
|
|
|
exit(channel)
Terminate a created process, closing the given 'channel'. |
source code
|
|
|
start(callable,
*args,
**kw)
Create a new process which shall start running in the given 'callable'. |
source code
|
|
|
start_persistent(address,
callable,
*args,
**kw)
Create a new process which shall be reachable using the given 'address' and
which will start running in the given 'callable'. |
source code
|
|
|
close_streams()
Close streams which keep the current process attached to any creating
processes. |
source code
|
|
|
waitall()
Wait for all created processes to terminate. |
source code
|
|