美文网首页
线程池的工作流程理解与项目中实战

线程池的工作流程理解与项目中实战

作者: 阡陌昏晨 | 来源:发表于2019-03-28 11:03 被阅读0次

    线程池主要处理流程

    1.线程池判断核心线程是否已经满了,否 则会创建线程执行任务,是 进入下一个流程
    2.线程池判断工作队列是否满了,否 把将要执行的任务加入队列,是 进入下一个流程
    3.线程池判断线程池是否满了,否 创建线程执行任务,是进入下一个流程
    4.线程池满了,按照策略处理无法执行的任务

    项目中的实战

    public class ExecutorSupport {
      /**cpu个数
     */
      private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors();
      /**
         * 线程池运行的核心线程数
         */
        private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT - 1, 4));
        
        /**
         * 线程池最大线程数
         */
        private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;
        
        /**
         * 线程空闲后的存活时长
         */
        private static final int KEEP_ALIVE = 3;
        
        /**
         * 采用ThreadFactory管理线程
         */
        private static final ThreadFactory sThreadFactory = new ThreadFactory() {
            /**
             * 线程index
             */
            private final AtomicInteger mCount = new AtomicInteger(1);
    
            /**
             * {@inheritDoc}
             */
            @Override
            public Thread newThread(Runnable r) {
                return new Thread(r, "Framework lib Thread #" + mCount.getAndIncrement());
            }
        };
    
        /**
         * 提交到线程池的Runnable队列
         */
        private static final BlockingQueue<Runnable> sPoolWorkQueue =
                new LinkedBlockingQueue<Runnable>(10);
    
        /**
         * 线程池
         */
        private static final ThreadPoolExecutor sExecutor
                = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
                        TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);
    
        /**
         * 获取线程池
         * @return 线程池
         */
        public static Executor getExecutor() {
            return sExecutor;
        }
        
        /**
         * 关闭线程池
         */
        public static void shutdown() {
            if (!sExecutor.isShutdown()) {
                sExecutor.shutdown();            
            }
        }
    }
    

    使用方式
    ExecutorSupport.getExecutor().execute(new Runnable() {
    @Override
    public void run() {
    // doSomething();
    }
    }

    相关文章

      网友评论

          本文标题:线程池的工作流程理解与项目中实战

          本文链接:https://www.haomeiwen.com/subject/qggfbqtx.html