如何使用Java的Worker类?
作者:OpenWorld
时间:2023-04-27
浏览:4
说明1、Worker是ThreadPoolexecutor的内部类,主要用于维持线程执行任务的中断控制状态。2、在实现Runnable接口的同时继承AQS,实现Runnable接口意味着Worker是线程。实例privatefinalclassWorkerextendsAbstractQueuedSynchronizerimplementsRunnable{/***Thisclasswillneverbeserialized,butweprovidea*serialVersionUIDtosuppress
本文目录
说明
1、Worker是ThreadPoolexecutor的内部类,主要用于维持线程执行任务的中断控制状态。
2、在实现Runnable接口的同时继承AQS,实现Runnable接口意味着Worker是线程。
实例
private final class Worker
extends AbstractQueuedSynchronizer
implements Runnable{
/**
* This class will never be serialized, but we provide a
* serialVersionUID to suppress a javac warning.
*/
private static final long serialVersionUID = 6138294804551838833L;
/** Thread this worker is running in. Null if factory fails. */
// 执行任务的线程
final Thread thread;
/** Initial task to run. Possibly null. */
// 执行的任务
Runnable firstTask;
/** Per-thread task counter */
volatile long completedTasks;
/**
* Creates with given first task and thread from ThreadFactory.
* @param firstTask the first task (null if none)
*/
Worker(Runnable firstTask) {
// 新建线程的时候,设置state -1 是为了防止线程还未执行时(线程只有在执行的时候才会被中断),就被 // 其它线程显式调用shutdown方法中断了,因为中断是要判断state大于等于0才会中断
setState(-1);
this.firstTask = firstTask;
// 新建了一个线程
this.thread = getThreadFactory().newThread(this);
}
/** Delegates main run loop to outer runWorker */
public void run() {
runWorker(this);
}
作者最新文章
PDF图片太多怎么批量压缩?PDF文档如何压缩变小?
2026-10-27 11:48
花4700元买RTX 5070:收到却是一堆20年前的电子垃圾!
2026-10-26 16:25
Aperty人像精修指南:去除面部红晕斑点与调整阴影
2026-10-22 21:53
即梦AI怎么导出到剪映继续剪辑?
2026-10-22 19:49
PDF转TXT小说怎么不乱码?手机PDF转TXT用哪个?
2026-10-17 16:32
热门文章
更多
精品专题
更多
Mac软件
更多
WINDOWS
更多

































