Examples of ThreadPoolFactory

com.sun.corba.ee.spi.orbutil.threadpool.ThreadPoolFactory
com.sun.corba.ee.spi.threadpool.ThreadPoolFactory
com.sun.sgs.nio.channels.ThreadPoolFactory
An object that creates thread pools on demand.
A thread pool factory is primarily intended for cases where an object creates thread pools on demand, and another object or entity requires control over the configuration and thread priority, group, etc.
An implementation will typically use the factory methods defined by the {@link java.util.concurrent.Executors Executors} class to create thethread pool.
[[Note: JSR-203 creates this interface in {@code java.util.concurrent}]]
org.apache.camel.spi.ThreadPoolFactory
Creates ExecutorService and ScheduledExecutorService objects that work with a thread pool for a given ThreadPoolProfile and ThreadFactory. This interface allows to customize the creation of these objects to adapt camel for application servers and other environments where thread pools should not be created with the jdk methods

Examples of com.sun.corba.ee.spi.orbutil.threadpool.ThreadPoolFactory

            }
        }
*/


        // Mutiplied the idleTimeoutInSeconds by 1000 to convert to milliseconds
        ThreadPoolFactory threadPoolFactory = new ThreadPoolFactory();
        ThreadPool threadpool =
                threadPoolFactory.create(minThreads, maxThreads,
                        idleTimeoutInSeconds * 1000, threadpoolId,
                        _iiopUtils.getCommonClassLoader());


        // Add the threadpool instance to the threadpoolList
        threadpoolList.add(threadpool);

View Full Code Here

Examples of com.sun.corba.ee.spi.threadpool.ThreadPoolFactory

            }
        }
*/


        // Mutiplied the idleTimeoutInSeconds by 1000 to convert to milliseconds
        ThreadPoolFactory threadPoolFactory = new ThreadPoolFactory();
        ThreadPool threadpool =
                threadPoolFactory.create(minThreads, maxThreads,
                        idleTimeoutInSeconds * 1000L, threadpoolId,
                        _iiopUtils.getCommonClassLoader());


        // Add the threadpool instance to the threadpoolList
        threadpoolList.add(threadpool);

View Full Code Here

Examples of com.sun.corba.ee.spi.threadpool.ThreadPoolFactory

            }
        }
*/


        // Mutiplied the idleTimeoutInSeconds by 1000 to convert to milliseconds
        ThreadPoolFactory threadPoolFactory = new ThreadPoolFactory();
        ThreadPool threadpool =
                threadPoolFactory.create(minThreads, maxThreads,
                        idleTimeoutInSeconds * 1000L, threadpoolId,
                        _iiopUtils.getCommonClassLoader());


        // Add the threadpool instance to the threadpoolList
        threadpoolList.add(threadpool);

View Full Code Here

Examples of com.sun.corba.ee.spi.threadpool.ThreadPoolFactory

            }
        }
*/


        // Mutiplied the idleTimeoutInSeconds by 1000 to convert to milliseconds
        ThreadPoolFactory threadPoolFactory = new ThreadPoolFactory();
        ThreadPool threadpool =
                threadPoolFactory.create(minThreads, maxThreads,
                        idleTimeoutInSeconds * 1000L, threadpoolId,
                        _iiopUtils.getCommonClassLoader());


        // Add the threadpool instance to the threadpoolList
        threadpoolList.add(threadpool);

View Full Code Here

Examples of com.sun.corba.ee.spi.threadpool.ThreadPoolFactory

            }
        }
*/


        // Mutiplied the idleTimeoutInSeconds by 1000 to convert to milliseconds
        ThreadPoolFactory threadPoolFactory = new ThreadPoolFactory();
        ThreadPool threadpool =
                threadPoolFactory.create(minThreads, maxThreads,
                        idleTimeoutInSeconds * 1000L, threadpoolId,
                        _iiopUtils.getCommonClassLoader());


        // Add the threadpool instance to the threadpoolList
        threadpoolList.add(threadpool);

View Full Code Here

Examples of com.sun.sgs.nio.channels.ThreadPoolFactory

     * @throws IOException if an I/O error occurs
     */
    private AsyncGroupImpl defaultGroup() throws IOException {
        synchronized (this) {
            if (defaultGroupInstance == null) {
                ThreadPoolFactory tpf = getThreadPoolFactory();
                ExecutorService executor = tpf.newThreadPool();
                defaultGroupInstance = openAsynchronousChannelGroup(executor);
                defaultGroupInstance.uncaughtHandler = defaultUncaughtHandler;
                defaultUncaughtHandler = null;
            }
            return defaultGroupInstance;

View Full Code Here

Examples of com.sun.sgs.nio.channels.ThreadPoolFactory

     * @throws IOException if an I/O error occurs
     */
    private AsyncGroupImpl defaultGroup() throws IOException {
        synchronized (this) {
            if (defaultGroupInstance == null) {
                ThreadPoolFactory tpf = getThreadPoolFactory();
                ExecutorService executor = tpf.newThreadPool();
                defaultGroupInstance = openAsynchronousChannelGroup(executor);
                defaultGroupInstance.uncaughtHandler = defaultUncaughtHandler;
                defaultUncaughtHandler = null;
            }
            return defaultGroupInstance;

View Full Code Here

Examples of org.apache.camel.spi.ThreadPoolFactory

        ExecutorServiceManager executorServiceStrategy = getBeanForType(ExecutorServiceManager.class);
        if (executorServiceStrategy != null) {
            LOG.info("Using custom ExecutorServiceStrategy: {}", executorServiceStrategy);
            getContext().setExecutorServiceManager(executorServiceStrategy);
        }
        ThreadPoolFactory threadPoolFactory = getBeanForType(ThreadPoolFactory.class);
        if (threadPoolFactory != null) {
            LOG.info("Using custom ThreadPoolFactory: {}", threadPoolFactory);
            getContext().getExecutorServiceManager().setThreadPoolFactory(threadPoolFactory);
        }
        ProcessorFactory processorFactory = getBeanForType(ProcessorFactory.class);

View Full Code Here

Examples of org.apache.camel.spi.ThreadPoolFactory

        ExecutorServiceManager executorServiceStrategy = getBeanForType(ExecutorServiceManager.class);
        if (executorServiceStrategy != null) {
            LOG.info("Using custom ExecutorServiceStrategy: {}", executorServiceStrategy);
            getContext().setExecutorServiceManager(executorServiceStrategy);
        }
        ThreadPoolFactory threadPoolFactory = getBeanForType(ThreadPoolFactory.class);
        if (threadPoolFactory != null) {
            LOG.info("Using custom ThreadPoolFactory: {}", threadPoolFactory);
            getContext().getExecutorServiceManager().setThreadPoolFactory(threadPoolFactory);
        }
        ProcessorFactory processorFactory = getBeanForType(ProcessorFactory.class);

View Full Code Here

Examples of org.apache.camel.spi.ThreadPoolFactory

        ExecutorServiceManager executorServiceStrategy = getBeanForType(ExecutorServiceManager.class);
        if (executorServiceStrategy != null) {
            LOG.info("Using custom ExecutorServiceStrategy: " + executorServiceStrategy);
            getContext().setExecutorServiceManager(executorServiceStrategy);
        }
        ThreadPoolFactory threadPoolFactory = getBeanForType(ThreadPoolFactory.class);
        if (threadPoolFactory != null) {
            LOG.info("Using custom ThreadPoolFactory: " + threadPoolFactory);
            getContext().getExecutorServiceManager().setThreadPoolFactory(threadPoolFactory);
        }
        ProcessorFactory processorFactory = getBeanForType(ProcessorFactory.class);

View Full Code Here

0 1 2

TOP

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.