hara.io.concurrent — hara/io.concurrent 3.0.12

add clj

(add queue element)

deque clj

(deque)

fixed-queue clj

(fixed-queue size)

get-queue clj

(get-queue service)

pool-executor clj

(pool-executor size max keep-alive)

(pool-executor size max keep-alive queue)

pop clj

(pop queue)

process-queue clj

(process-queue f queue maximum)

push clj

(push queue element)

queue clj

(queue)

shutdown clj

(shutdown service)

shutdown-now clj

(shutdown-now service)

single-executor clj

(single-executor)

(single-executor size)

submit clj

(submit service f)

(submit service f min-time)

submit-notify clj

(submit-notify service f)

(submit-notify service f min-time)

take clj

(take queue)

wrap-min-time clj

(wrap-min-time f ms)