disruptor.core — com.github.hden/disruptor 0.1.0

add-handlers! clj

(add-handlers! disruptor {:keys [handlers]})

Set up event handlers to handle events from the disruptor.

disruptor clj

(disruptor {:keys [size event-factory default-exception-handler]})

Create a new Disruptor.

publish! clj

(publish! disruptor {:keys [event event-translator]})

Publish an event.

shutdown! clj

(shutdown! disruptor)

(shutdown! disruptor {:keys [timeout unit]})

Waits until all events currently in the disruptor have been processed by all event processors and then halts the processors.

start! clj

(start! disruptor)

Start the disruptor.