001    /**
002     * Licensed to the Apache Software Foundation (ASF) under one or more
003     * contributor license agreements.  See the NOTICE file distributed with
004     * this work for additional information regarding copyright ownership.
005     * The ASF licenses this file to You under the Apache License, Version 2.0
006     * (the "License"); you may not use this file except in compliance with
007     * the License.  You may obtain a copy of the License at
008     *
009     *      http://www.apache.org/licenses/LICENSE-2.0
010     *
011     * Unless required by applicable law or agreed to in writing, software
012     * distributed under the License is distributed on an "AS IS" BASIS,
013     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
014     * See the License for the specific language governing permissions and
015     * limitations under the License.
016     */
017    package org.apache.activemq.thread;
018    
019    import java.util.concurrent.Executor;
020    import java.util.concurrent.ScheduledThreadPoolExecutor;
021    import java.util.concurrent.ThreadFactory;
022    
023    /**
024     * 
025     * 
026     */
027    public final class DefaultThreadPools {
028    
029    //    private static final Executor DEFAULT_POOL;
030    //    static {
031    //        DEFAULT_POOL = new ScheduledThreadPoolExecutor(5, new ThreadFactory() {
032    //            public Thread newThread(Runnable runnable) {
033    //                Thread thread = new Thread(runnable, "ActiveMQ Default Thread Pool Thread");
034    //                thread.setDaemon(true);
035    //                return thread;
036    //            }
037    //        });
038    //    }    
039        private static final TaskRunnerFactory DEFAULT_TASK_RUNNER_FACTORY = new TaskRunnerFactory();
040        
041        private DefaultThreadPools() {        
042        }
043        
044    //    public static Executor getDefaultPool() {
045    //        return DEFAULT_POOL;
046    //    }
047        
048        public static TaskRunnerFactory getDefaultTaskRunnerFactory() {
049            return DEFAULT_TASK_RUNNER_FACTORY;
050        }
051    
052        /**
053         * Useful to cleanup when it is known that all brokers and connections are
054         * close and stopped, eg: when un deploying from web container.
055         */
056        public static void shutdown() {
057            DEFAULT_TASK_RUNNER_FACTORY.shutdown();
058        }
059        
060    }