public DataCarrier consume(IConsumer<T> consumer, int num) {
        return this.consume(consumer, num, 200);
    }
set consumeDriver to this Carrier. consumer begin to run when {@link DataCarrier#produce} begin to work with 200
millis consume cycle.

@param consumer single instance of consumer, all consumer threads will all use this instance.
@param num      number of consumer threads
oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/DataCarrier.java