| | | |
Offset 353, 15 lines modified | Offset 353, 15 lines modified |
353 | </dd></dl> | 353 | </dd></dl> |
| |
354 | </div> | 354 | </div> |
355 | <div·class="section"·id="module-taskflow.conductors.backends.impl_nonblocking"> | 355 | <div·class="section"·id="module-taskflow.conductors.backends.impl_nonblocking"> |
356 | <span·id="non-blocking"></span><h3>Non-blocking<a·class="headerlink"·href="#module-taskflow.conductors.backends.impl_nonblocking"·title="Permalink·to·this·headline">¶</a></h3> | 356 | <span·id="non-blocking"></span><h3>Non-blocking<a·class="headerlink"·href="#module-taskflow.conductors.backends.impl_nonblocking"·title="Permalink·to·this·headline">¶</a></h3> |
357 | <dl·class="class"> | 357 | <dl·class="class"> |
358 | <dt·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"> | 358 | <dt·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"> |
359 | <em·class="property">class·</em><code·class="descclassname">taskflow.conductors.backends.impl_nonblocking.</code><code·class="descname">NonBlockingConductor</code><span·class="sig-paren">(</span><em>name</em>,·<em>jobboard</em>,·<em>persistence=None</em>,·<em>engine=None</em>,·<em>engine_options=None</em>,·<em>wait_timeout=None</em>,·<em>log=None</em>,·<em>max_simultaneous_jobs=17</em>,·<em>executor_factory=None</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../_modules/taskflow/conductors/backends/impl_nonblocking.html#NonBlockingConductor"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"·title="Permalink·to·this·definition">¶</a></dt> | 359 | <em·class="property">class·</em><code·class="descclassname">taskflow.conductors.backends.impl_nonblocking.</code><code·class="descname">NonBlockingConductor</code><span·class="sig-paren">(</span><em>name</em>,·<em>jobboard</em>,·<em>persistence=None</em>,·<em>engine=None</em>,·<em>engine_options=None</em>,·<em>wait_timeout=None</em>,·<em>log=None</em>,·<em>max_simultaneous_jobs=16</em>,·<em>executor_factory=None</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../_modules/taskflow/conductors/backends/impl_nonblocking.html#NonBlockingConductor"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"·title="Permalink·to·this·definition">¶</a></dt> |
360 | <dd><p>Bases:·<a·class="reference·internal"·href="#taskflow.conductors.backends.impl_executor.ExecutorConductor"·title="taskflow.conductors.backends.impl_executor.ExecutorConductor"><code·class="xref·py·py-class·docutils·literal·notranslate"><span·class="pre">taskflow.conductors.backends.impl_executor.ExecutorConductor</span></code></a></p> | 360 | <dd><p>Bases:·<a·class="reference·internal"·href="#taskflow.conductors.backends.impl_executor.ExecutorConductor"·title="taskflow.conductors.backends.impl_executor.ExecutorConductor"><code·class="xref·py·py-class·docutils·literal·notranslate"><span·class="pre">taskflow.conductors.backends.impl_executor.ExecutorConductor</span></code></a></p> |
361 | <p>Non-blocking·conductor·that·processes·job(s)·using·a·thread·executor.</p> | 361 | <p>Non-blocking·conductor·that·processes·job(s)·using·a·thread·executor.</p> |
362 | <dl·class="docutils"> | 362 | <dl·class="docutils"> |
363 | <dt>NOTE(harlowja):·A·custom·executor·factory·can·be·provided·via·keyword</dt> | 363 | <dt>NOTE(harlowja):·A·custom·executor·factory·can·be·provided·via·keyword</dt> |
364 | <dd>argument·<code·class="docutils·literal·notranslate"><span·class="pre">executor_factory</span></code>,·if·provided·it·will·be | 364 | <dd>argument·<code·class="docutils·literal·notranslate"><span·class="pre">executor_factory</span></code>,·if·provided·it·will·be |
365 | invoked·at | 365 | invoked·at |
366 | <a·class="reference·internal"·href="#taskflow.conductors.base.Conductor.run"·title="taskflow.conductors.base.Conductor.run"><code·class="xref·py·py-meth·docutils·literal·notranslate"><span·class="pre">run()</span></code></a>·time | 366 | <a·class="reference·internal"·href="#taskflow.conductors.base.Conductor.run"·title="taskflow.conductors.base.Conductor.run"><code·class="xref·py·py-meth·docutils·literal·notranslate"><span·class="pre">run()</span></code></a>·time |
Offset 370, 15 lines modified | Offset 370, 15 lines modified |
370 | to·submit·jobs·to.·If·<code·class="docutils·literal·notranslate"><span·class="pre">None</span></code>·is·a·provided·a·thread·pool | 370 | to·submit·jobs·to.·If·<code·class="docutils·literal·notranslate"><span·class="pre">None</span></code>·is·a·provided·a·thread·pool |
371 | backed·executor·is·selected·by·default·(it·will·have | 371 | backed·executor·is·selected·by·default·(it·will·have |
372 | an·equivalent·number·of·workers·as·this·conductors | 372 | an·equivalent·number·of·workers·as·this·conductors |
373 | simultaneous·job·count).</dd> | 373 | simultaneous·job·count).</dd> |
374 | </dl> | 374 | </dl> |
375 | <dl·class="attribute"> | 375 | <dl·class="attribute"> |
376 | <dt·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"> | 376 | <dt·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"> |
377 | <code·class="descname">MAX_SIMULTANEOUS_JOBS</code><em·class="property">·=·17</em><a·class="headerlink"·href="#taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"·title="Permalink·to·this·definition">¶</a></dt> | 377 | <code·class="descname">MAX_SIMULTANEOUS_JOBS</code><em·class="property">·=·16</em><a·class="headerlink"·href="#taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"·title="Permalink·to·this·definition">¶</a></dt> |
378 | <dd><p>Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same·time.</p> | 378 | <dd><p>Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same·time.</p> |
379 | </dd></dl> | 379 | </dd></dl> |
| |
380 | </dd></dl> | 380 | </dd></dl> |
| |
381 | </div> | 381 | </div> |
382 | </div> | 382 | </div> |