promesa.exec.bulkhead — funcool/promesa 9.0.518

Bulkhead pattern: limiter of concurrent executions.

create clj

(create &
        {:keys [executor concurrency queue-size on-run on-queue]
         :or {concurrency 1 queue-size Integer/MAX_VALUE}
         :as params})

IQueue clj protocol

-offer! clj

(-offer! _ _)

-poll! clj

(-poll! _)