(make-task-runner wname
body-fn
executor
watcher
timeout-ms
{:keys [in-flight? dropped-count num-runs num-errors
last-error last-run total-runtime last-duration
avg-duration]})Return a single-arg fn suitable for chime/chime-at callbacks.
IMPORTANT: The returned fn is non-blocking. It submits work to the worker executor
and submits a watcher task that waits with timeout, updates metrics, and clears
in-flight?. This allows accurate drop-while-running accounting.
Return a single-arg fn suitable for `chime/chime-at` callbacks. IMPORTANT: The returned fn is non-blocking. It submits work to the worker executor and submits a watcher task that waits with timeout, updates metrics, and clears `in-flight?`. This allows accurate drop-while-running accounting.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |