PYME.ParallelTasks.DSTaskQueue module

Created on Thu Nov 26 23:59:45 2015

@author: david

class PYME.ParallelTasks.DSTaskQueue.DSTaskQueue(name, mdh, dataSourceModule, dataSourceID, resultsFilename=None, onEmpty=<function doNix>, fTaskToPop=<function popZero>, startAt=10)

Bases: PYME.ParallelTasks.HDFTaskQueue.HDFResultsTaskQueue

task queue which, when initialised with an hdf image filename, automatically generates tasks - should also (eventually) include support for dynamically adding to data file for on the fly analysis

Methods

cleanup()
getNumberOpenTasks([exact])
getQueueData(fieldName, *args) Get data, defined by fieldName and potentially additional arguments, associated with queue
getTask([workerN, NWorkers]) get task from front of list, blocks
getTasks([workerN, NWorkers]) get task from front of list, blocks
postTask(task)
postTasks(tasks)
releaseTasks([startingAt])
cleanup()
getNumberOpenTasks(exact=True)
getQueueData(fieldName, *args)

Get data, defined by fieldName and potentially additional arguments, associated with queue

getTask(workerN=0, NWorkers=1)

get task from front of list, blocks

getTasks(workerN=0, NWorkers=1)

get task from front of list, blocks

postTask(task)
postTasks(tasks)
releaseTasks(startingAt=0)