public class ScheduledThreadPoolExecutor
extends ThreadPoolExecutor
implements ScheduledExecutorService {

public interface ScheduledExecutorService extends ExecutorService {

ScheduledExecutorService多了四个延时或周期任务接口

//达到给定的延时时间后，执行任务。这里传入的是实现Runnable接口的任务，
//因此通过ScheduledFuture.get()获取结果为null
public ScheduledFuture<?> schedule(Runnable command,long delay, TimeUnit unit);
//达到给定的延时时间后，执行任务。这里传入的是实现Callable接口的任务，
//因此，返回的是任务的最终计算结果public <V> ScheduledFuture<V> schedule(Callable<V> callable,long delay, TimeUnit unit);//是以上一个任务开始的时间计时，period时间过去后，
//检测上一个任务是否执行完毕，如果上一个任务执行完毕，
//则当前任务立即执行，如果上一个任务没有执行完毕，则需要等上一个任务执行完毕后立即执行
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit);
//当达到延时时间initialDelay后，任务开始执行。上一个任务执行结束后到下一次
//任务执行，中间延时时间间隔为delay。以这种方式，周期性执行任务。
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit);

使用

    public static void main(String[] args) throws ExecutionException, InterruptedException {ScheduledExecutorService pool = Executors.newScheduledThreadPool(4);System.out.println("main " + new Date());ScheduledFuture<?> schedule = pool.schedule(new Runnable() {@Overridepublic void run() {System.out.println("schedule Runnable " + new Date());}}, 1, TimeUnit.SECONDS);System.out.println(schedule.get());ScheduledFuture<Integer> schedule1 = pool.schedule(new Callable<Integer>() {@Overridepublic Integer call() throws Exception {System.out.println("schedule Callable " + new Date());return 1;}}, 2, TimeUnit.SECONDS);System.out.println(schedule1.get());}

main Wed Sep 04 11:07:42 CST 2019
schedule Runnable Wed Sep 04 11:07:43 CST 2019
null
schedule Callable Wed Sep 04 11:07:45 CST 2019
1

scheduleAtFixedRate使用

延时1秒后，执行第一次任务，周期2秒过后，再次执行任务

    public static void main(String[] args) throws ExecutionException, InterruptedException {ScheduledExecutorService pool = Executors.newScheduledThreadPool(4);System.out.println("main " + new Date());ScheduledFuture<?> schedule = pool.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {System.out.println("schedule Runnable " + new Date());}}, 1, 2, TimeUnit.SECONDS);System.out.println(schedule.get());}

main Wed Sep 04 11:14:06 CST 2019
schedule Runnable Wed Sep 04 11:14:07 CST 2019
schedule Runnable Wed Sep 04 11:14:09 CST 2019
schedule Runnable Wed Sep 04 11:14:11 CST 2019

如果任务时间3秒，大于周期时间2秒，等待任务执行完毕后，立即再次执行任务

    public static void main(String[] args) throws ExecutionException, InterruptedException {ScheduledExecutorService pool = Executors.newScheduledThreadPool(4);System.out.println("main " + new Date());ScheduledFuture<?> schedule = pool.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {System.out.println("schedule Runnable " + new Date());try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}}}, 1, 2, TimeUnit.SECONDS);System.out.println(schedule.get());}

main Wed Sep 04 11:16:12 CST 2019
schedule Runnable Wed Sep 04 11:16:13 CST 2019
schedule Runnable Wed Sep 04 11:16:16 CST 2019
schedule Runnable Wed Sep 04 11:16:19 CST 2019

scheduleWithFixedDelay使用

等待任务执行完毕后，延时2秒，再次执行任务

   public static void main(String[] args) throws ExecutionException, InterruptedException {ScheduledExecutorService pool = Executors.newScheduledThreadPool(4);System.out.println("main " + new Date());ScheduledFuture<?> schedule = pool.scheduleWithFixedDelay(new Runnable() {@Overridepublic void run() {System.out.println("schedule Runnable " + new Date());try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}}}, 1, 2, TimeUnit.SECONDS);System.out.println(schedule.get());}

main Wed Sep 04 11:18:11 CST 2019
schedule Runnable Wed Sep 04 11:18:12 CST 2019
schedule Runnable Wed Sep 04 11:18:17 CST 2019
schedule Runnable Wed Sep 04 11:18:22 CST 2019

ScheduledThreadPoolExecutor相关推荐

ScheduledThreadPoolExecutor()定时执行线程池详解，java线程池
为什么80%的码农都做不了架构师?>>> package com.dy.pool;import java.util.concurrent.ExecutorService; im ...
ScheduledThreadPoolExecutor详解
2019独角兽企业重金招聘Python工程师标准>>> 本文主要分为两个部分,第一部分首先会对ScheduledThreadPoolExecutor进行简单的介绍,并且会介绍其主要A ...
ScheduledThreadPoolExecutor的相关知识
转载请标明出处:[顾林海的博客] 个人开发的微信小程序,目前功能是书籍推荐,后续会完善一些新功能,希望大家多多支持! ##前言 ScheduledThreadPoolExecutor继承自Thread ...
(二十)java多线程之ScheduledThreadPoolExecutor
本人邮箱: <kco1989@qq.com> 欢迎转载,转载请注明网址 http://blog.csdn.net/tianshi_kco github: https://github.co ...
java定时器返回future_java 定时器线程池（ScheduledThreadPoolExecutor）的实现
前言定时器线程池提供了定时执行任务的能力,即可以延迟执行,可以周期性执行.但定时器线程池也还是线程池,最底层实现还是ThreadPoolExecutor,可以参考我的另外一篇文章多线程–精通Thre ...
ScheduledThreadPoolExecutor定时任务线程池执行原理分析
一.示例代码 @Slf4j public class ScheduleThreadPoolTest {private static ScheduledExecutorService executor ...
使用ScheduledThreadPoolExecutor代替TimerTimerTask
如果我们想要延迟(deferred)或者周期性(periodic)执行一个任务,我们可以使用Java API 的Timer和TimerTask类. 一般步骤是: 继承TimerTask(抽象类),复写 ...
线程池之ScheduledThreadPoolExecutor线程池源码分析笔记
1.ScheduledThreadPoolExecutor 整体结构剖析. 1.1类图介绍根据上面类图图可以看到Executor其实是一个工具类,里面提供了好多静态方法,根据用户选择返回不同的线程池 ...
Java并发编程—ScheduledThreadPoolExecutor原理分析
原文作者:小付原文地址:ScheduledThreadPoolExecutor原理分析目录一.简单使用二.类UML图三.处理流程四.任务提交方式五.SchduledFutureTask之 ...
java定时线程池_java 定时器线程池（ScheduledThreadPoolExecutor）的实现
前言定时器线程池提供了定时执行任务的能力,即可以延迟执行,可以周期性执行.但定时器线程池也还是线程池,最底层实现还是ThreadPoolExecutor,可以参考我的另外一篇文章多线程–精通Thre ...

ScheduledThreadPoolExecutor

使用

scheduleAtFixedRate使用

scheduleWithFixedDelay使用

ScheduledThreadPoolExecutor相关推荐

最新文章

热门文章