Disruptor实现EventFactory接口创建实例对象

创建具体实体类

package com656463.quickstart;

public class OrderEvent {

   /**
    * 订单的价格
    */
   private long value;

   public long getValue() {
      return value;
   }

   public void setValue(long value) {
      this.value = value;
   }
   
}

实现 EventFactory 工厂类接口，重写newInstance方法，在此方法中创建对象

package com656463.quickstart;

import com.lmax.disruptor.EventFactory;

/**
 * 创建EventFactory工厂类，用于创建实例对象
 */
public class OrderEventFactory implements EventFactory<OrderEvent> {

    /**
     * 返回空的数据对象（Event）
     *
     * @return
     */
    @Override
    public OrderEvent newInstance() {
        return new OrderEvent();
    }

}

此时创建对象的逻辑就完成了，接下来看怎么使用。