private void initializeExecutor() {
        if (!this.executorInitialized) {
            this.executorInitialized = true;
            this.asyncCreateConnectionExecutor = new ThreadPoolExecutor(minPoolSize, maxPoolSize,
                keepAliveTime, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueSize),
                new NamedThreadFactory("Bolt-conn-warmup-executor", true));
        }
    }
private void initializeExecutor() {
        if (!this.executorInitialized) {
            this.executorInitialized = true;
            this.asyncCreateConnectionExecutor = new ThreadPoolExecutor(minPoolSize, maxPoolSize,
                keepAliveTime, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueSize),
                new NamedThreadFactory("Bolt-conn-warmup-executor", true));
        }
    }
private void initializeExecutor ( ) { if ( ! this . executorInitialized ) { this . executorInitialized = true ; this . asyncCreateConnectionExecutor = new ThreadPoolExecutor ( minPoolSize , maxPoolSize , keepAliveTime , TimeUnit . SECONDS , new ArrayBlockingQueue < Runnable > ( queueSize ) , new NamedThreadFactory ( "Bolt-conn-warmup-executor" , true ) ) ; } }
initialize executor
initialize executor