原文作者:szlcy

原文地址:jdk 1.8 之 ScheduledThreadPoolExecutor 定时任务的退出和取消

package com.dosrain.shunc.trial.schedule;import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.concurrent.*;public class PoolTest2 {public static void main(String[] args) {// 设置一个同步计算数,目的是让子线程完成工作后,主线程再继续工作。// 因为这里只有一个子线程,所以设值为 1CountDownLatch countDownLatch = new CountDownLatch(1);// 创建线程池ScheduledThreadPoolExecutor pool = new ScheduledThreadPoolExecutor(1);// 创建固定时延的定时任务ScheduledFuture<?> scheduledFuture = pool.scheduleWithFixedDelay(new Task2(countDownLatch, 10), 0, 2, TimeUnit.SECONDS);try {// 暂停主线程,等待同步计算数器归零后,主线程再继续工作countDownLatch.await();// 同步计数器已归零,说明定时任务已满足条件退出// 所以取消定时任务scheduledFuture.cancel(true);} catch (InterruptedException e) {e.printStackTrace();}// 关闭线程池pool.shutdown();}
}class Task2 implements Runnable {CountDownLatch countDownLatch;private int counter;public Task2(CountDownLatch countDownLatch, int counter) {this.countDownLatch = countDownLatch;this.counter = counter;}@Overridepublic void run() {LocalDateTime localDateTime = LocalDateTime.now();DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");// 处理一些任务System.out.println(localDateTime.format(dtf) + " [" + Thread.currentThread().getName() + "] " + counter);if (counter-- == 0) {// 判断达到停止任务的条件countDownLatch.countDown();}}
}

程序执行结果:
2020-07-13 15:37:54 [pool-1-thread-1] 10
2020-07-13 15:37:56 [pool-1-thread-1] 9
2020-07-13 15:37:58 [pool-1-thread-1] 8
2020-07-13 15:38:00 [pool-1-thread-1] 7
2020-07-13 15:38:02 [pool-1-thread-1] 6
2020-07-13 15:38:04 [pool-1-thread-1] 5
2020-07-13 15:38:06 [pool-1-thread-1] 4
2020-07-13 15:38:08 [pool-1-thread-1] 3
2020-07-13 15:38:10 [pool-1-thread-1] 2
2020-07-13 15:38:12 [pool-1-thread-1] 1
2020-07-13 15:38:14 [pool-1-thread-1] 0

Process finished with exit code 0

要注意到是2秒打印一次

Java并发编程—如何取消定时任务相关推荐

  1. Java并发编程71道面试题及答案

    Java并发编程71道面试题及答案 1.在java中守护线程和本地线程区别? java中的线程分为两种:守护线程(Daemon)和用户线程(User). 任何线程都可以设置为守护线程和用户线程,通过方 ...

  2. Java并发编程75道面试题及答案

    1.在java中守护线程和本地线程区别?java中的线程分为两种:守护线程(Daemon)和用户线程(User).任何线程都可以设置为守护线程和用户线程,通过方法Thread.setDaemon(bo ...

  3. Java并发编程实战————Executor框架与任务执行

    引言 本篇博客介绍通过"执行任务"的机制来设计应用程序时需要掌握的一些知识.所有的内容均提炼自<Java并发编程实战>中第六章的内容. 大多数并发应用程序都是围绕&qu ...

  4. Java并发编程73道面试题及答案 —— 面试稳了 侵立删

    作者:乌枭 来自:https://blog.csdn.net/qq_34039315/article/details/78549311 最近后台和微信理有很多读者让我整理一些面试题,我就把这事放在心上 ...

  5. 干货推荐|Java并发编程核心概念一览,面试必备!

    本文由读者 muggle 投稿,muggle 是一位具备极客精神的 90 后单身老实猿,对 Java 并发编程有着深入研究,本文较长,大伙认真读完一定会有所收获.muggle 个人博客地址是 http ...

  6. 《Java 并发编程实战》--读书笔记

    Java 并发编程实战 注: 极客时间<Java 并发编程实战>–读书笔记 GitHub:https://github.com/ByrsH/Reading-notes/blob/maste ...

  7. java并发编程学习一

    java并发编程学习一 什么是进程和线程? 进程是操作系统进行资源分配的最小单位 进程跟进程之间的资源是隔离的,同一个进程之中的线程可以共享进程的资源. 线程是进程的一个实体,是CPU 调度和分派的基 ...

  8. Java并发编程有多难?这几个核心技术你掌握了吗?

    本文主要内容索引 1.Java线程 2.线程模型 3.Java线程池 4.Future(各种Future) 5.Fork/Join框架 6.volatile 7.CAS(原子操作) 8.AQS(并发同 ...

  9. Java并发编程--ReentrantReadWriteLock

    概述 ReentrantReadWriteLock是Lock的另一种实现方式,我们已经知道了ReentrantLock是一个排他锁,同一时间只允许一个线程访问,而ReentrantReadWriteL ...

最新文章

  1. 【UER #8】打雪仗
  2. NLP神器—Gensim
  3. 学习面试题Day02
  4. bat php 监控网站,bat curl 发送http请求 监控网站
  5. NYOJ 24 素数距离问题
  6. java程序设计实验报告册_20145215《Java程序设计》实验一实验报告
  7. 内置模块/核心模块 (自带的)---http 服务器模块
  8. C# 隐藏TabControl头
  9. WebLogic在Linux环境下安装
  10. 企业风险定价中的Expected loss估计
  11. 《小米网抢购系统开发实践》读后感
  12. 实现Canvas2D绘图 使元素绕中心居中旋转
  13. 游戏音效素材大全下载 - 3000首高清无损-按分类整理
  14. cmd下载的python包,pycharm中却无法使用(由于虚拟环境)
  15. [经典力学]牛顿自然哲学的数学原理论文解读
  16. MVX Android设计架构浅析-MVP
  17. Dense biased networks with deep priori anatomy and hard region adaptation: Semi-supervised learning
  18. CSS 之 后代、并列选择器
  19. 抽象类和抽象方法详解
  20. Spring Boot四大神器之Auto Configuration

热门文章

  1. size()函数的使用
  2. AngularJs angular.bind、angular.bootstrap、angular.copy
  3. java 中的对象序列化
  4. shopt_Linux命令
  5. linux入门_韩顺平_复习版_文件目录类
  6. Python -- 循环技巧(Looping Techniques)
  7. 面试题分享【不断更新】
  8. hdu 2025 查找最大元素
  9. docker 安装ElasticSearch 6.x
  10. ls 命令还能这么玩?看一下这 20 个实用范例