private ThreadPoolExecutor orderly(final DataEvent<T> t) {
        if (t instanceof OrderlyDataEvent && !isEmpty(((OrderlyDataEvent<T>) t).getHash())) {
            return executor.select(((OrderlyDataEvent<T>) t).getHash());
        } else {
            return executor;
        }
    }
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