public StatData pull(long timeout, TimeUnit unit) throws InterruptedException {
        return queue.poll(timeout, unit);
    }
Pull data

@param timeout
@param unit
@return
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/channel/DataQueue.java