promesa.exec.bulkhead — funcool/promesa 10.0.594

Bulkhead pattern: limiter of concurrent executions.

bulkhead? clj

(bulkhead? o)

Check if the provided object is instance of Bulkhead type.

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! _)