| | |
- threading.Thread(threading._Verbose)
-
- _DThread
- Worker
-
- MonoThreadedWorker
- MultiThreadedWorker
class MonoThreadedWorker(Worker) |
| |
Worker with just one thread
|
| |
Methods defined here:
- __init__(self)
- start(self)
Data and non-method functions defined here:
- __doc__ = 'Worker with just one thread'
- __module__ = 'common.worker'
Methods inherited from Worker:
- execFunction(self, func, *args)
- stop(self)
- Method to end gracefully the worker
Data and non-method functions inherited from Worker:
- STOP_MESSAGE = 44567
- WORKER_QUEUE_SIZE = 200
|
class MultiThreadedWorker(Worker) |
| |
Worker with multiple threads
|
| |
Methods defined here:
- __init__(self, howmany=10)
- start(self)
- stop(self)
Data and non-method functions defined here:
- MULTITHREAD_WORKER_NTHREADS = 10
- __doc__ = 'Worker with multiple threads'
- __module__ = 'common.worker'
Methods inherited from Worker:
- execFunction(self, func, *args)
Data and non-method functions inherited from Worker:
- STOP_MESSAGE = 44567
- WORKER_QUEUE_SIZE = 200
|
class Worker |
| |
Basic Unity of Workers. This works like this: this class contains a
queue; when you want to pass a function to execute to the worker, you
call execFunction(function, arguments ...) and it puts a tuple (function,
arguments) on the queue. Upper classes have mono or multiple threads
whose run() function is to 1) get the next element on this queue, 2)
execute its content, 3) goto 1 ;) See {Mono,Multi}ThreadedWorker for more
see common/testworker.py for examples.
Note: You should *not* use this class directly
|
| |
Methods defined here:
- __init__(self)
- execFunction(self, func, *args)
- stop(self)
- Method to end gracefully the worker
Data and non-method functions defined here:
- STOP_MESSAGE = 44567
- WORKER_QUEUE_SIZE = 200
- __doc__ = 'Basic Unity of Workers. This works like this: th... Note: You should *not* use this class directly'
- __module__ = 'common.worker'
|
|