Pyro Parallelisation

class nested_sampling.pyro_worker(dispatcher_URI, mc_runner, worker_name=None, host=None, port=0, serializer='pickle', server_type='multiplex')

Bases: object

the worker starts a demon that picks work times from the queue

class nested_sampling.DispatcherQueue

Bases: object

Methods

getResult([timeout])
getWork([timeout])
putResult(item)
putWork(item)
resultQueueSize()
workQueueSize()

getResult(timeout=0)

getWork(timeout=0)

putResult(item)

putWork(item)

resultQueueSize()

workQueueSize()