java定时器线程池（ScheduledThreadPoolExecutor）的实现前⾔
定时器线程池提供了定时执⾏任务的能⼒，即可以延迟执⾏，可以周期性执⾏。但定时器线程池也还是线程池，最底层实现还是ThreadPoolExecutor，可以参考我的另外⼀篇⽂章多线程–精通ThreadPoolExecutor。
特点说明
1.构造函数
public ScheduledThreadPoolExecutor(int corePoolSize) {
// 对于其他⼏个参数在ThreadPoolExecutor中都已经详细分析过了，所以这⾥，将不再展开
// 这⾥我们可以看到调⽤基类中的⽅法时有个特殊的⼊参DelayedWorkQueue。
// 同时我们也可以发现这⾥并没有设置延迟时间、周期等参数⼊⼝。
// 所以定时执⾏的实现必然在DelayedWorkQueue这个对象中了。
super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
new DelayedWorkQueue());
}
2.DelayedWorkQueue
salut法语DelayedWorkQueue是在ScheduledThreadPoolExecutor的⼀个内部类，实现了BlockingQueue接⼝
⾥⾯存放任务队列的数组如下：
private RunnableScheduledFuture<?>[] queue =
分词短语new RunnableScheduledFuture<?>[INITIAL_CAPACITY];
我们分析过ThreadPoolExecutor，它从任务队列中获取任务的⽅式为poll和take两种，所以看⼀下poll和take两个⽅法的源码，回顾⼀下，ThreadPoolExecutor它会调⽤poll或take⽅法，先poll，再take，只要其中⼀个接⼝有返回就⾏
public RunnableScheduledFuture<?> poll() {
final ReentrantLock lock = this.lock;
lock.lock();
try {贤惠的意思
RunnableScheduledFuture<?> first = queue[0];
// 这⾥有个getDelay，这是关键点，获取执⾏延时时间
// 但是如果我们有延时设置的话，这就返回空了，然后就会调⽤take⽅法
if (first == null || Delay(NANOSECONDS) > 0)
return null;
el
return finishPoll(first);
} finally {
lock.unlock();
}
}
public RunnableScheduledFuture<?> take() throws InterruptedException {
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
for (;;) {
RunnableScheduledFuture<?> first = queue[0];
if (first == null)
available.await();
el {
/
/ 获取延时时间
火星哥好听的歌
long delay = Delay(NANOSECONDS);
if (delay <= 0)
return finishPoll(first);
first = null; // don't retain ref while waiting
if (leader != null)
学盘头化妆
available.await();
el {
Thread thisThread = Thread.currentThread();
leader = thisThread;
try {
/
/ 使⽤锁，执⾏延时等待。
// 使⽤锁，执⾏延时等待。
// 使⽤锁，执⾏延时等待。
available.awaitNanos(delay);
} finally {
ivy是什么意思
if (leader == thisThread)
leader = null;
人际关系的重要性}
星期一到星期天的英文
}
}
}
} finally {
if (leader == null && queue[0] != null)
available.signal();
lock.unlock();
}
}
3.RunnableScheduledFuture
在ScheduledThreadPoolExecutor内部有⼀个ScheduledFutureTask类实现了RunnableScheduledFuture，ScheduledFutureTask这个类采⽤了装饰者设计模式，在执⾏Runnable的⽅法基础上还执⾏了⼀些额外的功能。
我们需要特别注意⼏个参数period、time。
（1）time
⾸先看⼀下time的作⽤，可以发现time是⽤于获取执⾏延时时间的，也就是delay是根据time⽣成的
public long getDelay(TimeUnit unit) {
vert(time - now(), NANOSECONDS);
}
（2）period
这个参数不是说设置执⾏⼏个周期，⽽是⽤于判断是否需要按周期执⾏，以及执⾏周期，也就是本次执⾏与下次执⾏间隔的时间
// 判断是否需要按周期执⾏，如果周期设置成0，不是⽆间隔执⾏，⽽是只执⾏⼀次，这个需要特别注意
public boolean isPeriodic() {
return period != 0;
}
private void tNextRunTime() {
long p = period;
if (p > 0)
// 这⾥将周期加给time，这样获取的延迟时间就是周期时间了。
time += p;
el
involve是什么意思
time = triggerTime(-p);
}
（3）执⾏
public void run() {
// 先判断是否为周期性的任务
boolean periodic = isPeriodic();
if (!canRunInCurrentRunState(periodic))
cancel(fal);
el if (!periodic)
// 如果不是周期性的，就执⾏调⽤⽗类的run⽅法，也就是构造函数中传⼊的Runnable对象的run⽅法。
ScheduledFutureTask.super.run();
// 在if的括号中先执⾏了任务
el if (ScheduledFutureTask.super.runAndRet()) {
// 如果是周期性的，就需要设置下次执⾏的时间，然后利⽤reExecutePeriodic⽅法，将任务再次丢⼊任务队列中。
// 这⾥尤其需要注意的是if中的逻辑执⾏失败，如果没有捕捉异常，那么后⾯的逻辑就不会再执⾏了，
也就是说中间有⼀次执⾏失败，后⾯这个周期性的任务就失效了。 tNextRunTime();
reExecutePeriodic(outerTask);
}
}
总结
ScheduledThreadPoolExecutor通过time参数，设置当前任务执⾏的等待时间，再通过period设置任务下次执⾏需要等待的时间。这两个参数都不是设置在线程池中的，⽽是携带在任务中的，这就可以把线程池和任务进⾏完全解耦。zhouqu
注意点：
（1）任务的执⾏等待时间是在队列的take⽅法中的。
（2）period参数设置成0，任务将只会执⾏⼀次，⽽不会执⾏多次
（3）如果要⾃⼰实现周期性Task，周期性任务在执⾏过程中，⼀定要注意捕捉异常，否则某⼀次执
⾏失败，将导致后续的任务周期失效，任务将不再继续执⾏。
到此这篇关于java 定时器线程池（ScheduledThreadPoolExecutor）的实现的⽂章就介绍到这了，更多相关java 定时器线程池内容请搜索以前的⽂章或继续浏览下⾯的相关⽂章希望⼤家以后多多⽀持！
