public void run()

in src/main/java/org/apache/skywalking/banyandb/commons/datacarrier/consumer/ConsumerThread.java [48:66]

• 14 lines of code
• 4 McCabe index (conditional complexity)

    public void run() {
        running = true;

        final List<T> consumeList = new ArrayList<T>(1500);
        while (running) {
            if (!consume(consumeList)) {
                try {
                    Thread.sleep(consumeCycle);
                } catch (InterruptedException e) {
                }
            }
        }

        // consumer thread is going to stop
        // consume the last time
        consume(consumeList);

        consumer.onExit();
    }