The following is a small scheduler for making as many tasks available
to the consumer threads It uses the serial shuffling system
|
|
__init__(self,
bld,
j=2)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature |
source code
|
|
|
|
get_next(self)
override this method to schedule the tasks in a particular order |
source code
|
|
|
|
postpone(self,
tsk)
override this method to schedule the tasks in a particular order |
source code
|
|
|
|
refill_task_list(self)
called to set the next group of tasks |
source code
|
|
|
|
get_out(self)
the tasks that are put to execute are all collected using get_out |
source code
|
|
|
|
error_handler(self,
tsk)
by default, errors make the build stop (not thread safe so be
careful) |
source code
|
|
|
|
|
|
Inherited from object:
__delattr__,
__getattribute__,
__hash__,
__new__,
__reduce__,
__reduce_ex__,
__repr__,
__setattr__,
__str__
|