(dochan pool on-input in-chan blocked?)Calls on-input on each item found on in-chan, using the gated thread pool.
Calls on-input on each item found on in-chan, using the gated thread pool.
(gated-execute {:keys [semaphore threadpool]} f)Executes f on gated-threadpool. Will throw
RejectedExecutionException if gated-threadpool is being shutdown.
Executes `f` on `gated-threadpool`. Will throw RejectedExecutionException if `gated-threadpool` is being shutdown.
(gated-threadpool size name-pattern shutdown-timeout-ms)Creates an unbounded threadpool with the intent that access to the
threadpool is bounded by the semaphore. Implicitly the threadpool is
bounded by size, but since the semaphore is handling that aspect,
it's more efficient to use an unbounded pool and not duplicate the
constraint in both the semaphore and the threadpool
Creates an unbounded threadpool with the intent that access to the threadpool is bounded by the semaphore. Implicitly the threadpool is bounded by `size`, but since the semaphore is handling that aspect, it's more efficient to use an unbounded pool and not duplicate the constraint in both the semaphore and the threadpool
Exception handler that ensures any uncaught exception that occurs on this thread is logged
Exception handler that ensures any uncaught exception that occurs on this thread is logged
(shutdown {:keys [threadpool shutdown-timeout]})Shuts down the threadpool, ensuring in-flight work is
complete before tearing it down. Waits up to shutdown-timeout (in
milliseconds) for that work to complete before forcibly shutting
down the threadpool
Shuts down the threadpool, ensuring in-flight work is complete before tearing it down. Waits up to `shutdown-timeout` (in milliseconds) for that work to complete before forcibly shutting down the threadpool
(shutdown-gated {:keys [semaphore] :as pool})Shuts down the gated threadpool via shutdown-pool after draining all the permits.
Shuts down the gated threadpool via shutdown-pool after draining all the permits.
(thread-factory threadpool-name-pattern pool-thread-factory)Creates a command thread factory, wrapping the
pool-thread-factory. Using this thread factory ensures that we
have distinguishable names for threads in this pool and that all
uncaught exceptions are logged as errors. Without this uncaught
exceptions get the default which is standard error
Creates a command thread factory, wrapping the `pool-thread-factory`. Using this thread factory ensures that we have distinguishable names for threads in this pool and that all uncaught exceptions are logged as errors. Without this uncaught exceptions get the default which is standard error
(unbounded-threadpool name-pattern shutdown-timeout-ms)Creates an unbounded thread pool with PuppetDB specific adjustments, i.e. exception logging, etc.
Creates an unbounded thread pool with PuppetDB specific adjustments, i.e. exception logging, etc.
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 |