源码深度分析线程池中Worker线程的执行流程
需积分: 9 184 浏览量
2022-08-26
11:20:38
上传
评论
收藏 85KB PDF 举报
在《 》一文高并发之——通过ThreadPoolExecutor类的源码深度解析线程池执行任务的核心流程
中我们深度分析了线程池执行任务的核心流程，在ThreadPoolExecutor类的addWorker
(Runnable, boolean)方法中，使用CAS安全的更新线程的数量之后，接下来就是创建新的Worker
线程执行任务，所以，我们先来分析下Worker类的源码。
Worker类分析
Worker类从类的结构上来看，继承了AQS（AbstractQueuedSynchronizer类）并实现了Runnable接
口。本质上，Worker类既是一个同步组件，也是一个执行任务的线程。接下来，我们看下Worker
类的源码，如下所示。
{private final class Worker extends AbstractQueuedSynchronizer implements Runnable
;private static final long serialVersionUID = 6138294804551838833L
//
Thread thread;final
//
Runnable firstTask;
//
completedTasks;volatile long
//Worker
Worker(Runnable firstTask) {
setState(- ); 1
.firstTask = firstTask;this
.thread = getThreadFactory().newThread( );this this
}
//Runnablerun()
{public void run()
//ThreadPoolExecutorrunWorker(Worker)
runWorker( );this
}
//
//state=0
//state=1
{protected boolean isHeldExclusively()
getState() != ;return 0
}
//AQS
{protected boolean tryAcquire( unused)int
(compareAndSetState( , )) {if 0 1
setExclusiveOwnerThread(Thread.currentThread());
;return true
}
;return false
}
//
{protected boolean tryRelease( unused)int
setExclusiveOwnerThread( );null
setState( );0
;return true
资源评论
