org.apache.shenyu.disruptor.provider

类 DisruptorProvider<T>

java.lang.Object

org.apache.shenyu.disruptor.provider.DisruptorProvider<T>

类型参数:

T - the type parameter

public class DisruptorProvider<T>
extends java.lang.Object

DisruptorProvider. disruptor provider definition.

构造器概要

构造器

构造器和说明
DisruptorProvider(com.lmax.disruptor.RingBuffer<DataEvent<T>> ringBuffer, com.lmax.disruptor.dsl.Disruptor<DataEvent<T>> disruptor, boolean isOrderly) Instantiates a new Disruptor provider.

方法概要

限定符和类型	方法和说明
void	onData(T data) Send a data.
void	onOrderlyData(T data, java.lang.String... hashArray) On orderly data.
void	shutdown() Shutdown.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DisruptorProvider

public DisruptorProvider(com.lmax.disruptor.RingBuffer<DataEvent<T>> ringBuffer,
                         com.lmax.disruptor.dsl.Disruptor<DataEvent<T>> disruptor,
                         boolean isOrderly)

Instantiates a new Disruptor provider.

参数:

ringBuffer - the ring buffer

disruptor - the disruptor

isOrderly - the orderly Whether to execute sequentially.

方法详细资料

onData

public void onData(T data)

Send a data.

参数:

data - the data

onOrderlyData

public void onOrderlyData(T data,
                          java.lang.String... hashArray)

On orderly data.

参数:

data - the data

hashArray - the hashArray.

shutdown

public void shutdown()

Shutdown.