Index

_

__add_to_active_tasks() (Server method) __annotations__ (_Task attribute) (Copier attribute), [1] (ParallelPool attribute), [1] (Pipe attribute), [1] (ProcessPool attribute), [1] (SerialPool attribute), [1] (ThreadPool attribute), [1] (Tunnel attribute) (TunnelException attribute) (XMLRPCRequestHandler attribute) (XMLRPCServer attribute), [1] __call__() (_Task method) (ApplyResult method) (Copier method), [1] (MapResult method) (Pipe method), [1], [2] (portnumber method) (profile method) (profiled method) __connect() (Server method) __del__() (Server method) __detect_ncpus() (Server method) __dict__ (_Task attribute) (AbstractPipeConnection attribute) (AbstractWorkerPool attribute) (MapResult attribute) (Pipe attribute) (portnumber attribute) (profile attribute) (profiled attribute) (Selector attribute) (Server attribute), [1] (Tunnel attribute), [1] __disconnect() (Tunnel method), [1] __dumpsfunc() (Server method) __enter__() (AbstractWorkerPool method) __exit__() (AbstractWorkerPool method) __find_modules() (Server method) __gentid() (Server method) __get_nodes() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1] __get_nodes__() (in module pathos.serial) __get_servers() (ParallelPool method), [1] __get_source() (Server method) __imap() (AbstractWorkerPool method) __init() (AbstractWorkerPool method) __init__() (_Task method) (AbstractPipeConnection method) (AbstractWorkerPool method) (ApplyResult method) (Copier method), [1] (MapResult method) (ParallelPool method), [1] (Pipe method), [1], [2] (portnumber method) (ProcessPool method), [1] (profile method) (profiled method) (Selector method) (Server method), [1] (ThreadPool method), [1] (Tunnel method), [1] (XMLRPCRequestHandler method), [1] (XMLRPCServer method), [1] __map() (AbstractWorkerPool method) __module__ (_Task attribute) (AbstractPipeConnection attribute) (AbstractWorkerPool attribute) (ApplyResult attribute) (Copier attribute), [1] (FileNotFound attribute) (MapResult attribute) (ParallelPool attribute), [1] (Pipe attribute), [1], [2] (PipeException attribute) (portnumber attribute) (ProcessPool attribute), [1] (profile attribute) (profiled attribute) (Selector attribute) (SerialPool attribute), [1] (Server attribute), [1] (ThreadPool attribute), [1] (TimeoutError attribute) (Tunnel attribute), [1] (TunnelException attribute), [1] (XMLRPCRequestHandler attribute), [1] (XMLRPCServer attribute), [1]

__nodes (AbstractWorkerPool attribute) __pipe() (AbstractWorkerPool method) __repr__() (AbstractPipeConnection method) (AbstractWorkerPool method) (ParallelPool method), [1] (Pipe method) (ProcessPool method), [1] (ThreadPool method), [1] (Tunnel method), [1] __scheduler() (Server method) __set_nodes() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1] __set_nodes__() (in module pathos.serial) __set_servers() (ParallelPool method), [1] __stat_add_job() (Server method) __stat_add_time() (Server method) __state__ (ParallelPool attribute), [1] (ProcessPool attribute), [1] (SerialPool attribute), [1] (ThreadPool attribute), [1] __unpickle() (ApplyResult method) (MapResult method) __update_active_rworkers() (Server method) __weakref__ (_Task attribute) (AbstractPipeConnection attribute) (AbstractWorkerPool attribute) (FileNotFound attribute) (MapResult attribute) (Pipe attribute) (PipeException attribute) (portnumber attribute) (profile attribute) (profiled attribute) (Selector attribute) (Server attribute), [1] (Tunnel attribute), [1] (TunnelException attribute), [1] _ApplyResult (in module pathos.helpers.pp_helper) _b() (in module pathos.util) _cleanup() (Selector method) _clear() (in module pathos.pools) (ParallelPool method), [1] (ProcessPool method), [1] (ThreadPool method), [1] _connect() (Tunnel method), [1] _debug (Pipe attribute) (Selector attribute) (XMLRPCRequestHandler attribute), [1] _dispatch() (Selector method) _equals() (ParallelPool method), [1] _execute() (Pipe method) _exiting (SerialPool attribute), [1] _handleMessageFromChild() (XMLRPCServer method), [1] _installSocket() (XMLRPCServer method), [1] _is_alive() (ParallelPool method), [1] (SerialPool method), [1] _MapResult (in module pathos.helpers.pp_helper) _marshaled_dispatch() (XMLRPCServer method), [1] _onConnection() (XMLRPCServer method), [1] _onSelectorIdle() (XMLRPCServer method), [1] _onSocketConnection() (XMLRPCServer method), [1] _pathos_connect module _portpicker module _ProcessPool (in module pathos.multiprocessing) (in module pathos.pools) _profiles (in module pathos.hosts) _registerChild() (XMLRPCServer method), [1] _run_local() (Server method) _run_remote() (Server method) _sendResponse() (XMLRPCRequestHandler method), [1] _serve() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (ThreadPool method), [1] _set() (MapResult method) _str() (in module pathos.util) _Task (class in pathos.helpers.pp_helper) _Task__unpickle() (_Task method) _ThreadPool() (in module pathos.pools) (in module pathos.threading) _TIMEOUT (Selector attribute) _unRegisterChild() (XMLRPCServer method), [1] _watch() (Selector method)

A

AbstractPipeConnection (class in pathos.abstract_launcher) AbstractWorkerPool (class in pathos.abstract_launcher) activate() (Server method) (XMLRPCServer method), [1] amap() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (ThreadPool method), [1]

apipe() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (ThreadPool method), [1] ApplyResult (class in pathos.helpers.pp_helper)

C

callback (ApplyResult property) callbackargs (ApplyResult property) citation() (in module pathos) clear() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1] clear_stats() (in module pathos.profile) close() (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1]

config() (Copier method), [1] (Pipe method), [1], [2] connect() (in module pathos.core) (Tunnel method), [1] connect1() (Server method) Copier (class in pathos.secure) (class in pathos.secure.copier) copy() (in module pathos.core) cpu_count() (in module pathos.helpers)

D

deactivate() (Server method) default_port (Server attribute) default_secret (Server attribute) destroy() (Server method)

disable_profiling() (in module pathos.profile) disconnect() (Tunnel method), [1] do_POST() (XMLRPCRequestHandler method), [1] dump_stats() (in module pathos.profile)

E

enable_profiling() (in module pathos.profile)

execute() (in module pathos.core)

F

FileNotFound finalize() (_Task method) (ApplyResult method) (MapResult method)

finished (ApplyResult property) freeze_support() (in module pathos.helpers)

G

get() (ApplyResult method) (MapResult method) get_active_nodes() (Server method) get_ncpus() (Server method) get_profile() (in module pathos.hosts) get_profiles() (in module pathos.hosts)

get_stats() (in module pathos.profile) (Server method) getchild() (in module pathos.core) getpid() (in module pathos.core) getppid() (in module pathos.core) group (ApplyResult property)

I

imap() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1]

insert() (Server method)

J

join() (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1]

K

kill() (in module pathos.core) (Pipe method)

L

launch() (Pipe method) license() (in module pathos)

lock (ApplyResult property) log_message() (XMLRPCRequestHandler method), [1] logger() (in module pathos)

M

map() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1] MapResult (class in pathos.helpers.pp_helper) MAXPORT (Tunnel attribute), [1] MINPORT (Tunnel attribute), [1] module _pathos_connect _portpicker pathos pathos.abstract_launcher pathos.connection pathos.core pathos.helpers pathos.helpers.mp_helper pathos.helpers.pp_helper pathos.hosts pathos.mp_map pathos.multiprocessing pathos.parallel pathos.pools pathos.portpicker pathos.pp pathos.pp_map pathos.profile pathos.python pathos.secure pathos.secure.connection pathos.secure.copier pathos.secure.tunnel pathos.selector pathos.serial pathos.server pathos.threading pathos.util pathos.xmlrpc pathos.xmlrpc.server

mp_map() (in module pathos.mp_map)

N

ncpus (ParallelPool property), [1] (ProcessPool property), [1] nodes (ParallelPool property), [1] (ProcessPool property), [1] (SerialPool property), [1] (ThreadPool property), [1]

not_profiled() (in module pathos.profile) notifyOnException() (Selector method) notifyOnInterrupt() (Selector method) notifyOnReadReady() (Selector method) notifyOnWriteReady() (Selector method) notifyWhenIdle() (Selector method) nthreads (ThreadPool property), [1]

P

ParallelPool (class in pathos.parallel) (class in pathos.pools) ParallelPythonPool (in module pathos.pp) pathos module pathos.abstract_launcher module pathos.connection module pathos.core module pathos.helpers module pathos.helpers.mp_helper module pathos.helpers.pp_helper module pathos.hosts module pathos.mp_map module pathos.multiprocessing module pathos.parallel module pathos.pools module pathos.portpicker module pathos.pp module pathos.pp_map module pathos.profile module pathos.python module pathos.secure module pathos.secure.connection module pathos.secure.copier module

pathos.secure.tunnel module pathos.selector module pathos.serial module pathos.server module pathos.threading module pathos.util module pathos.xmlrpc module pathos.xmlrpc.server module pid() (Pipe method) Pipe (class in pathos.connection) (class in pathos.secure) (class in pathos.secure.connection) pipe() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1] PipeException portnumber (class in pathos.portpicker) pp_map() (in module pathos.pp_map) ppmap() (in module pathos.pp_map) ppServer (in module pathos.pp_map) print_exc_info() (in module pathos.util) print_stats() (in module pathos.pp_map) (in module pathos.profile) (Server method) process_id() (in module pathos.profile) ProcessPool (class in pathos.multiprocessing) (class in pathos.pools) (in module pathos.helpers) profile (class in pathos.profile) profiled (class in pathos.profile) PythonSerial (in module pathos.python)

Q

queue() (MapResult method)

R

random_seed() (in module pathos.helpers.mp_helper) random_state() (in module pathos.helpers.mp_helper) randomport() (in module pathos.core) (in module pathos.portpicker) ready() (ApplyResult method) (MapResult method)

register() (in module pathos.hosts) register_profiles() (in module pathos.hosts) response() (Pipe method) restart() (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1]

S

Selector (class in pathos.selector) selector() (Server method) SerialPool (class in pathos.pools) (class in pathos.serial) serve() (in module pathos.core) (Server method) (XMLRPCServer method), [1] server (ApplyResult property) Server (class in pathos.helpers.pp_helper) (class in pathos.server) servers (ParallelPool property), [1] set_ncpus() (Server method)

shutdown() (in module pathos.helpers) spawn() (in module pathos.util) spawn2() (in module pathos.util) starargs() (in module pathos.helpers.mp_helper) start_profiling() (in module pathos.profile) stats() (in module pathos.parallel) (in module pathos.pp) (in module pathos.pp_map) stop_profiling() (in module pathos.profile) submit() (Server method) successful() (ApplyResult method) (MapResult method)

T

terminate() (ParallelPool method), [1] (ProcessPool method), [1] (SerialPool method), [1] (ThreadPool method), [1] thread_id() (in module pathos.profile) ThreadPool (class in pathos.pools) (class in pathos.threading)

ThreadPool() (in module pathos.helpers) tid (ApplyResult property) TimeoutError Tunnel (class in pathos.secure) (class in pathos.secure.tunnel) TunnelException, [1]

U

uimap() (AbstractWorkerPool method) (ParallelPool method), [1] (ProcessPool method), [1] (ThreadPool method), [1]

V

verbose (Pipe attribute) (Tunnel attribute), [1]

W

wait() (_Task method) (ApplyResult method) (MapResult method) (Server method)

watch() (Selector method)

X

XMLRPCRequestHandler (class in pathos.xmlrpc) (class in pathos.xmlrpc.server)

XMLRPCServer (class in pathos.xmlrpc) (class in pathos.xmlrpc.server)