一句话解释ThreadPoolExecutor添加线程(有源码)

ThreadPoolExecutor添加线程是通过 execute(Runnable command),此方法代码行数不多,但是由于太精炼了,不大好读懂,理解完之后,特写下笔记加深印象.

 

一句话解释:

如果BlockingQueue没有大小限制,如果在执行的线程个数小于corePoolSize,则自动执行,否则当前线程存入BlockingQueue.

 

备注:如果BlockingQueue有限制,超出的线程要么拒绝,要么抢跑直接执行(需要当前线程个数没有超过maximumPoolSize).

 

下面是具体的代码,已经添加注释,如果有问题欢迎大家指出.

 

//ThreadPoolExecutor
   public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();
		//--如果核心线程已经用尽( poolSize >= corePoolSize ), 进入if分支
		//--核心线程没用完,立即执行线程,不进入if分支(!addIfUnderCorePoolSize(command))
        if (poolSize >= corePoolSize /*核心线程没空余*/ || !addIfUnderCorePoolSize(command)/*核心线程有空余*/) {
		
			//--如果核心线程已经用尽, 并且runState == RUNNING, 则添加command到workQueue中去
            if (runState == RUNNING && workQueue.offer(command)) {
                if (runState != RUNNING || poolSize == 0)
					//如果线程池状态不为RUNNING,或者正在工作的线程个数为0,则尽量保证添加的Command被处理(Reject)
                    ensureQueuedTaskHandled(command);
            }
			//--如果workQueue已满,则尝试直接执行线程(需要保证当前运行线程<maximumPoolSize,感觉好像插队了一样,不公平)
            else if (!addIfUnderMaximumPoolSize(command))
				//如果poolSize>=maximumPoolSize,则拒绝(通过抛出运行时异常)
                reject(command); // is shutdown or saturated
        }
    }
	
  	
	

 

 

几点注意

1. workers中存放的是 正在执行的线程,当执行完毕,并且BlockingQueue中无数据时,线程会会自动从workers中删除 (通过Worker.workerDone(this))
2. workQueue中存放的是 由于corePoolSize限制,来不及执行的线程.如果由于workQueue的限制导致存放不下的,有可能抢跑而直接执行(前提是线程数量小于maximumPoolSize,否则直接拒绝).
3. ThreadPoolExecutor 构造函数中有2个限制:一个是核心线程数量,一个是最大线程数量. 上面函数不好理解是因为有一个可能潜在的限制,就是缓存队列(BlockingQueue)的大小限制.
4. 放入BlockingQueue中的线程何时执行: 每一个Worker初始化之后,会立即去执行,但是当执行完成之后即会尝试从BlockingQueue中取线程执行.下面是对应代码.

 

//Worker
        public void run() {
            try {
                Runnable task = firstTask;
                firstTask = null;
//task = getTask()就是尝试从队列中取线程来执行
                while (task != null || (task = getTask()) != null) {
                    runTask(task);
                    task = null;
                }
            } finally {
                workerDone(this);
            }
        }