Disruptor技術調研之WorkHandler

com.lmax.disruptor.WorkHandler<T> Callback interface to be implemented for processing units of work as they become available in the RingBuffer. EventHandler和該接口的區別是WorkHandler的概念是基於worker的處理池 Type Parameters: <T> event implementation storing the data for sharing during exchange or parallel coordination of an event. See Also: WorkerPool --->> com.lmax.disruptor.WorkerPool<T> WorkerPool contains a pool of WorkProcessors that will consume sequences so jobs can be farmed out across a pool of workers. Each of the WorkProcessors manage and calls a WorkHandler to process the events. Type Parameters: <T> event to be processed by a pool of workers 事件數據 --->> EventHandlerGroup<T> com.lmax.disruptor.dsl.Disruptor.handleEventsWithWorkerPool(WorkHandler<T>... workHandlers) Set up a WorkerPool to distribute an event to one of a pool of work handler threads. Each event will only be processed by one of the work handlers. The Disruptor will automatically start this processors when start() is called. 重點描述的是，每一個事件只會被池中的一個任務處理器進行處理 Parameters: workHandlers the work handlers that will process events. Returns: a EventHandlerGroup that can be used to chain dependencies.