public void initialize()

in src/main/java/com/epam/gmp/process/QueuedProcessService.java [49:57]

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

    public void initialize() {
        queue = new ArrayBlockingQueue<>(startPullers);
        threadPool = new QueuedProcessThreadPoolExecutor(corePullers, startPullers, 30L, TimeUnit.SECONDS, queue);

        if (logger.isInfoEnabled()) {
            logger.info("Prepared Groovy thread pool of {} pullers; concurrent: {}", startPullers, corePullers);
            logger.info("Initialized.");
        }
    }