Show More
@@ -131,13 +131,23 b' class TaskScheduler(SessionFactory):' | |||||
131 |
|
131 | |||
132 | """ |
|
132 | """ | |
133 |
|
133 | |||
134 |
hwm = Integer( |
|
134 | hwm = Integer(1, config=True, | |
135 | help="""specify the High Water Mark (HWM) for the downstream |
|
135 | help="""specify the High Water Mark (HWM) for the downstream | |
136 | socket in the Task scheduler. This is the maximum number |
|
136 | socket in the Task scheduler. This is the maximum number | |
137 |
of allowed outstanding tasks on each engine. |
|
137 | of allowed outstanding tasks on each engine. | |
|
138 | ||||
|
139 | The default (1) means that only one task can be outstanding on each | |||
|
140 | engine. Setting TaskScheduler.hwm=0 means there is no limit, and the | |||
|
141 | engines continue to be assigned tasks while they are working, | |||
|
142 | effectively hiding network latency behind computation, but can result | |||
|
143 | in an imbalance of work when submitting many heterogenous tasks all at | |||
|
144 | once. Any positive value greater than one is a compromise between the | |||
|
145 | two. | |||
|
146 | ||||
|
147 | """ | |||
138 | ) |
|
148 | ) | |
139 | scheme_name = Enum(('leastload', 'pure', 'lru', 'plainrandom', 'weighted', 'twobin'), |
|
149 | scheme_name = Enum(('leastload', 'pure', 'lru', 'plainrandom', 'weighted', 'twobin'), | |
140 |
'leastload', config=True, |
|
150 | 'leastload', config=True, allow_none=False, | |
141 | help="""select the task scheduler scheme [default: Python LRU] |
|
151 | help="""select the task scheduler scheme [default: Python LRU] | |
142 | Options are: 'pure', 'lru', 'plainrandom', 'weighted', 'twobin','leastload'""" |
|
152 | Options are: 'pure', 'lru', 'plainrandom', 'weighted', 'twobin','leastload'""" | |
143 | ) |
|
153 | ) |
General Comments 0
You need to be logged in to leave comments.
Login now