java 线程池执行流程源码讲解

Posted 2023-02-03 史上最强的弟子

threadPoolExecutor.execute(); //执行过程。
public void execute(Runnable command) 
        if (command == null)
            throw new NullPointerException();
         *
         * Proceed in 3 steps:
         *
         * 1. If fewer than corePoolSize threads are running, try to
         * start a new thread with the given command as its first
         * task.  The call to addWorker atomically checks runState and
         * workerCount, and so prevents false alarms that would add
         * threads when it shouldn't, by returning false.
         *
         * 2. If a task can be successfully queued, then we still need
         * to double-check whether we should have added a thread
         * (because existing ones died since last checking) or that
         * the pool shut down since entry into this method. So we
         * recheck state and if necessary roll back the enqueuing if
         * stopped, or start a new thread if there are none.
         *
         * 3. If we cannot queue task, then we try to add a new
         * thread.  If it fails, we know we are shut down or saturated
         * and so reject the task.
         *
		//获取运行线程数
        int c = ctl.get();
        //workerCountOf(c)获取工作线程个数是否小于核心线程数
        if (workerCountOf(c) < corePoolSize) 
        	//增加addWorker(command, true)  增加addWorker 第二个线程数是否核心
            if (addWorker(command, true))
                return;
            c = ctl.get();
        
        //如果大于核心线程数，判断是否运行，队列放入command
        if (isRunning(c) && workQueue.offer(command)) 
            int recheck = ctl.get();
			 没有运行线程，且可以进行队列出队列,执行拒绝策略（因为上次检查后已有的死亡）
            if (!isRunning(recheck) && remove(command))
                reject(command);
            如果工作
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        
        //如果添加非核心线程失败，走拒绝策略
        else if (!addWorker(command, false))
            reject(command);