qbits.knit — cc.qbits/knit 2.0.3

binding-conveyor-fn clj

deref-future clj

execute clj deprecated

Submits the fn to specified executor, returns a Future

executor clj

(executor type)

(executor type
          &
          {:keys [thread-factory num-threads]
           :or {num-threads (int 1)
                thread-factory (Executors/defaultThreadFactory)}})

Returns ExecutorService. type can be :single, :cached, :fixed or :scheduled, this matches the corresponding Java instances

future clj macro

(future & args)

Takes an executor instance and a body of expressions and yields a future object that will invoke the body in another thread, and will cache the result and return it on all subsequent calls to deref/@. If the computation has not yet finished, calls to deref/@ will block, unless the variant of deref with timeout is used..

future-call clj

(future-call f
             {:as _options
              :keys [executor preserve-bindings?]
              :or {preserve-bindings? true
                   executor clojure.lang.Agent/soloExecutor}})

Takes a function of no args and yields a future object that will invoke the function in another thread, and will cache the result and return it on all subsequent calls to deref/@. If the computation has not yet finished, calls to deref/@ will block, unless the variant of deref with timeout is used. See also - realized?.

schedule clj

(schedule type delay f)

(schedule type
          delay
          f
          &
          {:keys [executor initial-delay unit]
           :or {initial-delay 0 unit :milliseconds}})

Return a ScheduledFuture. type can be :with-fixed-delay, :at-fixed-rate, :once delay's default unit is milliseconds f task (function) to be run

submit clj

(submit executor f)

Submits the fn to specified executor, returns a Future

thread-factory clj

(thread-factory & {:keys [fmt priority daemon]})

thread-group clj

(thread-group name)

(thread-group parent name)

Returns a new ThreadGroup instance to be used in thread-factory

time-units clj