这篇文章给大家介绍如何进行ScheduledThreadPoolExecutor分析与线程池防坑,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
线程池默认使用无界队列,任务过多时,JVM OOM
不设置最大线程数,线程数目暴涨
定时执行,执行一次任务耗时太长甚至一直阻塞,达不到定时执行的目的
线程池内的线程是非守护线程,停止JVM时出问题
使用submit方法,没有调用future.get()导致异常被吞,execute不会有异常被吞的问题
死锁问题,并不常见,但是有时候写复杂了可能会出现。一句话,使用线程池和诸如阻塞队列这种抽象层次比较高的工具时,尽量不要再用低层次的类,如lock,wait(),notify()等,这样混用会导致难以排查的问题。
ScheduledExecutorService scheduledService = Executors.newScheduledThreadPool(4);
scheduledService.scheduleAtFixedRate(() -> {
try {
System.out.println("pool thread:" + Thread.currentThread().isDaemon());
System.out.println("start at:" + new Date());
Thread.sleep(10000);
System.out.println("end at:" + new Date());
} catch (InterruptedException e) {
e.printStackTrace();
}
}, 0, 5, TimeUnit.SECONDS);
上面的代码块意图每5秒执行一次任务,但是执行这个任务需要耗费10秒(sleep),那么肯定不能达到5秒一次的效果。分析一下原因。
定时执行功能的实现类是ScheduledThreadPoolExecutor
,它是一个线程池加延迟队列来实现的,延迟队列是使用堆来实现的,也就是根元素值最大或者值最小,在定时任务执行这个场景下,根元素就是下一个要执行的任务,然后有一个等待时间。
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) {
if (command == null || unit == null)
throw new NullPointerException();
if (period <= 0)
throw new IllegalArgumentException();
ScheduledFutureTask<Void> sft =
new ScheduledFutureTask<Void>(command,
null,
triggerTime(initialDelay, unit),
unit.toNanos(period));
RunnableScheduledFuture<Void> t = decorateTask(command, sft);
sft.outerTask = t;
delayedExecute(t);
return t;
}
然后看ScheduledFutureTask
这个类的run()
方法
public void run() {
boolean periodic = isPeriodic();//是否周期执行
if (!canRunInCurrentRunState(periodic))
cancel(false);
else if (!periodic)
ScheduledFutureTask.super.run();//不是执行一次就完了
else if (ScheduledFutureTask.super.runAndReset()) {//执行
setNextRunTime();//设置下次时间
reExecutePeriodic(outerTask);//加入队列
}
}
void reExecutePeriodic(RunnableScheduledFuture<?> task) {
if (canRunInCurrentRunState(true)) {
super.getQueue().add(task);
if (!canRunInCurrentRunState(true) && remove(task))
task.cancel(false);
else
ensurePrestart();//决定线程池是否新增线程,未达到核心线程数,有新任务则加线程
}
}
可以看到如果一次执行时间很长,是达不到定时执行的目的,最终的表现就是一次连着一次执行,如果我们确实需要精准的定期执行,不关注每次多长时间,该怎么办?很简单,再弄一个线程池专门用来干活
关于如何进行ScheduledThreadPoolExecutor分析与线程池防坑就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/wuxiaofei/blog/4556978