JAVA并发-ScheduledExecutorService_运动员写代码的博客-程序员秘密

技术标签: 并发  java  JAVA并发编程  java.util.concurrent包翻译文章  定时任务  

java.util.concurrent.ScheduledExecutorService是一个可以安排任务延迟执行的 ExecutorService , 或者以固定的时间间隔重复执行。任务通过一个工作线程异步执行,而不是提交任务到ScheduledExecutorService的线程。

ScheduledExecutorService例子

下面是ScheduledExecutorService例子:

ScheduledExecutorService scheduledExecutorService =
        Executors.newScheduledThreadPool(5);

ScheduledFuture scheduledFuture =
    scheduledExecutorService.schedule(new Callable() {
        public Object call() throws Exception {
            System.out.println("Executed!");
            return "Called!";
        }
    },
    5,
    TimeUnit.SECONDS);

 

首先,创建一个容纳5个线程的.然后,创建了Callable 接口的一个匿名类作为参数提交到Callable

ScheduledExecutorService实现

既然ScheduledExecutorService是个接口, ava.util.concurrent包中的ScheduledExecutorService 的类实现了该接口:

  • ScheduledThreadPoolExecutor

创建ScheduledExecutorService

创建 ScheduledExecutorService 取决于你用哪种实现,当然也可以Executors 的工厂方法创建ScheduledExecutorService  实例,下面是代码:

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);

 

ScheduledExecutorService用法

一旦创建了 ScheduledExecutorService,可以用下面方法 :

  • schedule (Callable task, long delay, TimeUnit timeunit)
  • schedule (Runnable task, long delay, TimeUnit timeunit)
  • scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit)
  • scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit)

下面一一讲解这些方法:

schedule (Callable task, long delay, TimeUnit timeunit)

这个方法安排给定得 Callable 延迟执行,这方法返回ScheduledFuture  ,可以用于在任务未执行前取消任务或者当执行完了获取返回结果,下面是代码:

ScheduledExecutorService scheduledExecutorService =
        Executors.newScheduledThreadPool(5);

ScheduledFuture scheduledFuture =
    scheduledExecutorService.schedule(new Callable() {
        public Object call() throws Exception {
            System.out.println("Executed!");
            return "Called!";
        }
    },
    5,
    TimeUnit.SECONDS);

System.out.println("result = " + scheduledFuture.get());

scheduledExecutorService.shutdown();

 

输出结果:

Executed!
result = Called!

 

schedule (Runnable task, long delay, TimeUnit timeunit)

这个方法类似于上面得方法,但是没有返回结果,所以任务完成 ScheduledFuture.get()将返回null

scheduleAtFixedRate (Runnable, long initialDelay, long period, TimeUnit timeunit)

这个方法安排任务间隔执行,任务首次在initialDelay以后执行,然后每次间隔initialDelay执行。如果任何一次抛异常,那么任务不再执行,如果没有异常,任务一直执行直到ScheduledExecutorService 关闭,如果当前线程执行时间很长,那么下一个任务要等到这个任务执行完成,在同一时间只执行一个任务。

scheduleWithFixedDelay (Runnable, long initialDelay, long period, TimeUnit timeunit)

这个方法和 scheduleAtFixedRate()非常相似,只是时间段有不同的解释。

在scheduleAtFixedRate()方法中,周期被解释为从上一次执行开始到下一次执行开始之间的延迟。

然而,在这种方法中,周期被解释为上一次执行结束到下一次执行开始之间的延迟。因此,延迟是在完成执行之间,而不是在执行开始之间。

ScheduledExecutorService Shutdown

 ExecutorService一样, 当任务执行完毕 ScheduledExecutorService需要关闭,如果不关闭,一直在JVM中运行,尽管其他线程已经关闭。

关闭ScheduledExecutorServiceshutdown() 或者 shutdownNow() 方法,这两个方法是从ExecutorService接口继承得, 可以查看前面文章 ExecutorService 中得Shutdown 

参考:https://blog.csdn.net/cgsyck/article/details/107692471

      http://tutorials.jenkov.com/java-util-concurrent/scheduledexecutorservice.html

       https://blog.csdn.net/cgsyck/article/details/107769550

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/cgsyck/article/details/107782607

智能推荐

android--GPS定位_android中gps定位_明月不明白的博客-程序员秘密

LocationManager 类该类供访问系统的位置服务。 该类不能直接实例化,必须通过Context.getSystemService(Context.LOCATION_SERVICE)获取该类对象。 所有位置API方法需要ACCESS_COARSE_LOCATION或ACCESS_FINE_LOCATION权限。Public Methods: boolean isProvider

变形卷积核、可分离卷积?卷积神经网络中十大拍案叫绝的操作。_weixin_34268843的博客-程序员秘密

从2012年的AlexNet发展至今,科学家们发明出各种各样的CNN模型,一个比一个深,一个比一个准确,一个比一个轻量。我下面会对近几年一些具有变革性的工作进行简单盘点,从这些充满革新性的工作中探讨日后的CNN变革方向。注:水平所限,下面的见解或许有偏差,望大牛指正。另外只介绍其中具有代表性的模型,一些著名的模型由于原理相同将不作介绍,若有遗漏也欢迎...

如何在CDH集群启用Kerberos_cdh 去除kerberos_wandy0211的博客-程序员秘密

1.文档编写目的本文档讲述如何在CDH集群启用及配置Kerberos,您将学习到以下知识:1.如何安装及配置KDC服务2.如何通过CDH启用Kerberos3.如何登录Kerberos并访问Hadoop相关服务文档主要分为以下几步:1.安装及配置KDC服务2.CDH集群启用Kerberos3.Ker

python相对导入报错_快速了解Python相对导入_weixin_39717825的博客-程序员秘密

1、绝对导入和相对导入绝对导入:按照sys.path顺序搜索,先主目录(sys.path中第一项''),然后PYTHONPATH环境变量、标准库路径、pth指定路径等。相对导入:在模块所在同一个包内搜索,注意该包目录与主目录的区别。例1:有以下目录app/__init__.pymod.pystring.pymod.py内容:import string当在app/目录下执行Python mod.py...

商城网站前台html模板,网上购物商城前台模板HTML源码_yueyhang cheuk的博客-程序员秘密

【实例简介】网上购物商城前台模板HTML源码 值得一用【实例截图】【核心代码】网上购物商城前台模板HTML源码└── 网上购物商城前台模板HTML源码├── about.html├── codes.html├── css│ ├── bootstrap.css│ ├── fasthover.css│ ├── flexslider.css│ ├── font-awesome.css│...

随便推点

Win10家庭版远程桌面 : 出现身份验证错误,要求的函数不受支持 可能是由于CredSSP加密Oracle修正。_KeepFang的博客-程序员秘密

Win10家庭版远程桌面 : 出现身份验证错误,要求的函数不受支持 可能是由于CredSSP加密Oracle修正。工具/原料Win10家庭版方法/步骤网上有说:经过“计算机配置”->“管理模板”->“系统”->“凭据分配”但是我的却找不到“加密Or

Linux运维进阶-文档总结-添加PHP的memcache缓存模块_大猩猩Bigstar的博客-程序员秘密

以下所有操作都是在Red-hat 6.5上1.Memcache的介绍Memcached是一个自由开源的,高性能,分布式内存对象缓存系统。它的简洁设计便于快速开发,减轻开发难度,解决了大数据量缓存的很多问题。它的API兼容大部分流行的开发语言。本质上,它是一个简洁的key-value存储系统。一般的使用目的是,通过缓存数据库查询结果,减少数据库访问次数,以提高动态...

linux磁盘清理方法 Linux 下垃圾清理工具 BleachBit_weixin_34278190的博客-程序员秘密

由于当初安装系统设计不合理,有些分区的过小,以及网络通讯故障等造成日志文件速度增长等其他原因都可以表现为磁盘空间满,造成无法读写磁盘,应用程序无法执行等。下面就给你支几招(以/home空间满为例):  1.定期对重要文件系统扫描,并作对比,分析那些文件经常读写  #IS-IR/home>;files.txt  #diff filesold.txt files.txt  通...

wifi的扫描调用过程(从supplicant到kernel)_wifi扫描内核调用过程_zhuyeguang的博客-程序员秘密

supplicant扫描的调用过程(使用nl80211)supplicant接收到”SCAN”命令后,由wpa_supplicant_ctrl_iface_process处理。wpa_supplicant_ctrl_iface_processwpas_ctrl_scan // 处理扫描命令wpa_supplicant_req_scanwpa_supplicant_scanwpa_supplicant_trigger_scanwpas_trigger_sc...

LeetCode #223 - Rectangle Area_LawFile的博客-程序员秘密

题目描述:Find the total area covered by two rectilinear rectangles in a 2D plane.Each rectangle is defined by its bottom left corner and top right corner as shown in the figure.Example:Input: A...

android wifi扫描间隔,[RK3399][Android7.1] 调试笔记 --- WiFi扫描周期规则_龙憩的博客-程序员秘密

Platform: RK3399OS: Android 7.1Kernel: v4.4.83亮屏情况:1. 在WiFi Settings界面,无论WiFi是否有连接,固定扫描时间间隔为10s。2. 在非WiFi Settings界面,无论WiFi是否有连接,以2的倍数慢慢拉大扫描周期,最小为20s,最大为160s灭屏情况:1. 当开启了PNO并且WiFi已经连接时,扫描周期为160s.2. 当开启...

推荐文章

热门文章

相关标签