            com.lmax.disruptor.RingBuffer
            com.lmax.disruptor.dsl.Disruptor
            com.lmax.disruptor.EventFactory
+           com.lmax.disruptor.EventTranslatorOneArg
            com.lmax.disruptor.EventHandler)
   (:require [com.stuartsierra.component :as component]
             [clojure.tools.logging      :refer [warn]]

  (reify EventFactory
    (newInstance [this]
      (ctor))))

(defn threadpool
  [sz]

(defcounter cnt-queue)
(defcounter cnt-errors)
(defonce default-poolsize 4)
(defonce default-capacity (int 1024))

(defprotocol QueueEngine
  (consume! [this k opts f])
