clj-countdown-latch.core
async-as-necessarycljmacro
(async-as-necessary & body)Dispatch the given body as a function sent to async-as-necessary*
Dispatch the given body as a function sent to `async-as-necessary*`
async-as-necessary*clj
(async-as-necessary* f)Execute the given function asynchronously, but only if we are in the context
of a with-countdown-latch*. Exceptions are not handled. If you want to see
stack traces, the code you send to this function must catch and handle them.
Execute the given function asynchronously, but only if we are in the context of a `with-countdown-latch*`. Exceptions are not handled. If you want to see stack traces, the code you send to this function must catch and handle them.
with-countdown-latchcljmacro
(with-countdown-latch timeout-ms & body)Dispatch the given body as a function sent to with-countdown-latch*
with the given timeout-ms
Dispatch the given body as a function sent to `with-countdown-latch*` with the given `timeout-ms`
with-countdown-latch*clj
(with-countdown-latch* timeout-ms f)Execute the given body with an executor to support async execution. Before the body is able to return, we will wait for all async events to complete. Using a Java-based Cached Thread Pool so we don't allow any events to block others, or waste memory creating new threads when we don't need to. See https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Executors.html#newCachedThreadPool()
Execute the given body with an executor to support async execution. Before the body is able to return, we will wait for all async events to complete. Using a Java-based Cached Thread Pool so we don't allow any events to block others, or waste memory creating new threads when we don't need to. See https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Executors.html#newCachedThreadPool()
wrap-ringclj
(wrap-ring timeout-ms handler)Provides a ring middleware that wraps an execution path in a countdown latch
Provides a ring middleware that wraps an execution path in a countdown latch
wrap-timbre-appenderclj
(wrap-timbre-appender appender-config)Reconfigures a timbre appender to use the countdown latch for its async processing instead of the built-in approach
Reconfigures a timbre appender to use the countdown latch for its async processing instead of the built-in approach
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close