@Override
    public void onEvent(final DataEvent<T> t) {
        if (Objects.nonNull(t)) {
            ThreadPoolExecutor executor = orderly(t);
            QueueConsumerExecutor<T> queueConsumerExecutor = factory.create();
            queueConsumerExecutor.setData(t.getData());
            // help gc
            t.setData(null);
            executor.execute(queueConsumerExecutor);
        }
    }
Instantiates a new Queue consumer.

@param executor the executor
@param factory  the factory
shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumer.java