public void begin()

in src/main/java/org/apache/skywalking/banyandb/commons/datacarrier/consumer/ConsumeDriver.java [85:99]

• 15 lines of code
• 3 McCabe index (conditional complexity)

    public void begin(Channels channels) {
        if (running) {
            return;
        }
        lock.lock();
        try {
            this.allocateBuffer2Thread();
            for (ConsumerThread consumerThread : consumerThreads) {
                consumerThread.start();
            }
            running = true;
        } finally {
            lock.unlock();
        }
    }