checks if executor is at capacity

await termination for executor service

returns number of active threads in pool

returns number of completed tasks

returns number of threads in pool

returns number of submitted tasks

gets the queue from the executor

(-> (executor:pool 10 10 1000 (q/queue)) (exec:get-queue))

increases the capacity of the executor

gets and sets the keep alive time

gets and sets the core pool max

gets and sets the core pool size

contructs a raw queue in different ways

(exec:queue)

(exec:queue 1)

(exec:queue {:size 1})

(exec:queue {})

(exec:queue (q/queue))

sets the rejected task handler

shuts down executor

shuts down executor immediately

checks if executor is shutdown

checks if executor is shutdown and all threads have finished

check that executor is terminating

creates an executor

(executor {:type :pool :size 3 :max 3 :keep-alive 1000})

creates a cached executor

(executor:cached)

returns health of the executor

returns executor service info

constructs a pool executor

(executor:pool 10 10 1000 {:size 10})

returns props for getters and setters

constructs a scheduled executor

(executor:scheduled 10)

registers a shared executor

lists all shared executors

(-> (executor:shared) keys sort) => :async :default :pooled

constructs a single executor

;; any sized pool (executor:single)

;; fixed pool (executor:single {:size 10})

returns executor service type

deregisters a shared executor

schedules task for execution

schedules task at fixed delay

schedules task at a fixed rate

submits a task to an executor

@(submit (executor:single) (fn []) {:min 100}) ^hidden

@(submit (executor:single) (fn [] (Thread/sleep 1000)) {:max 100}) => (throws)

submits a task (generally to a fixed size queue)

(doto (executor:single 1) (submit-notify (fn []) 1000) (submit-notify (fn []) 1000) (submit-notify (fn []) 1000))

wraps a function with min-time and delay

((wrap-min-time (fn []) 20 0))

((wrap-min-time (fn []) 100 10))