protected AbstractBulkWriteProcessor()

in src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java [60:84]

• 24 lines of code
• 2 McCabe index (conditional complexity)

    protected AbstractBulkWriteProcessor(STUB stub,
                                         String processorName,
                                         int maxBulkSize,
                                         int flushInterval,
                                         int concurrency,
                                         int timeout) {
        this.stub = stub;
        this.maxBulkSize = maxBulkSize;
        this.flushInterval = flushInterval;
        this.timeout = timeout;
        requests = new ArrayBlockingQueue<>(maxBulkSize + 1);
        this.semaphore = new Semaphore(concurrency > 0 ? concurrency : 1);

        scheduler = new ScheduledThreadPoolExecutor(1, r -> {
            final Thread thread = new Thread(r);
            thread.setName("BanyanDB BulkProcessor");
            return thread;
        });
        scheduler.setExecuteExistingDelayedTasksAfterShutdownPolicy(false);
        scheduler.setContinueExistingPeriodicTasksAfterShutdownPolicy(false);
        scheduler.setRemoveOnCancelPolicy(true);
        flushInternalInMillis = flushInterval * 1000;
        scheduler.scheduleWithFixedDelay(
            this, 0, flushInterval, TimeUnit.SECONDS);
    }