Package org.jrebirth.af.core.concurrent

Examples of org.jrebirth.af.core.concurrent.JRebirthThreadPoolExecutor


        LOGGER.trace(JTP_CREATION);

        final int poolSize = Math.max(1, Math.round(JRebirthParameters.THREAD_POOL_SIZE_RATIO.get() * Runtime.getRuntime().availableProcessors()));

        // Launch the default executor
        this.executorService = new JRebirthThreadPoolExecutor(poolSize,
                new NamedThreadBuilder(((AbstractApplication<?>) application).getPoolUncaughtExceptionHandler(), JTP_BASE_NAME));

        // Launch the High Priority executor
        this.highPriorityExecutorService = new JRebirthThreadPoolExecutor(poolSize,
                new NamedThreadBuilder(((AbstractApplication<?>) application).getPoolUncaughtExceptionHandler(), HPTP_BASE_NAME));

        trackEvent(JRebirthEventType.CREATE_GLOBAL_FACADE, getApplication().getClass(), this.getClass());

        // Build the notifier manager
View Full Code Here

TOP

Related Classes of org.jrebirth.af.core.concurrent.JRebirthThreadPoolExecutor

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.