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

智能推荐

计算机五大类型,操作系统目前有五大类型_糖小渣的博客-程序员秘密

操作系统目前来说一共有五种类型,那你知道分别是哪几个吗?下面由学习啦小编为大家整理了操作系统五大类型的相关知识,希望大家喜欢!一、操作系统五大类型的简介1. 批处理操作系统批处理(Batch Processing)操作系统的工作方式是:用户将作业交给系统操作员,系统操作员将许多用户的作业组成一批作业,之后输入到计算机中,在系统中形成一个自动转接的连续的作业流,然后启动操作系统,系统自动、依次执行每...

Activity生命周期及页面跳转(Intent)、数据传递_小Caicai的博客-程序员秘密

Activity用户与程序的交互是通过Activity完成的,Activity负责管理Android应用程序的登陆界面。1. Activity 的创建在程序包处单击右键,选择New → Activity → Empty Activity后会弹出Customize the Activity界面Activity Name :用于输入Activity名称。Layout Name:用输入布...

强化学习:DDPG到MADDPG_maddpg和ddpg_彩虹糖梦的博客-程序员秘密

本文主要关注于强化学习中基于策略梯度的方法。首先会简要介绍什么是策略梯度,什么是Actor-Critic算法,之后会重点讲述DDPG(Deep Deterministic Policy Gradient)算法,以及DDPG的多智能体版本:MADDG(Multi-agent Deep Deterministic Policy Gradient)。策略梯度(Policy Gradient)与基于策略梯度(Policy Based)的方法相对应的,是基于动作价值函数(Value Based)的方法。我们熟

k30s刷鸿蒙系统,Redmi K30S至尊版喜提MIUI 12.5稳定版_百菜物联的博客-程序员秘密

Redmi K30S至尊版喜提MIUI 12.5稳定版2021-05-07 13:20:0516点赞18收藏104评论进入5月,第二批升级MIUI 12.5的机型也陆续开启推送,在五一小长假期间包括Redmi K40标准版、小米CC9等机型均已收到MIUI 12.5稳定版的推送升级。今日,根据网友反馈,号称Redmi唯一的骁龙865 LCD旗舰——Redmi K30S至尊纪念版也在今日下午收到了M...

linux 访问挂载外接存储_weixin_34144848的博客-程序员秘密

为什么80%的码农都做不了架构师?>>> ...

Python数据分析与展示(三)--Matplotlib库_matplotlib导入_小西在这里的博客-程序员秘密

学习视频链接:Python数据分析与展示_北京理工大学_哔哩哔哩_bilibili P21-P35Matplotlib库入门一、Matplotlib库的导入Matplotlib库是python优秀的可视化第三方库Matplotlib库由各种可视化类构成,内部结构复杂,受Matlab启发,matplotlib.pyplot是绘制各类可视化图形的命令子库,相当与快捷方式。#plt是引入模块的别名,这是一种约定俗成的引入名称import matplotlib.pyplot as plt..

随便推点

1000款商务通用PPT模板免费下载_小黑猪���的博客-程序员秘密

2002-创意蓝色科技工业PPT模板.zip: https://baippt.ctfile.com/fs/5288276-3457499882003- 创意水墨中国风通用PPT模板.zip: https://baippt.ctfile.com/fs/5288276-3457500282004- 创意中国风文艺通用PPT模板.zip: https://baippt.ctfile.com/fs/...

npm下载慢问题_gsls200808的博客-程序员秘密

带宽测速https://www.speedtest.net/https://www.speedtest.cn/查看镜像地址npm config get registry#原始地址 https://registry.npmjs.org/淘宝镜像npm config set registry https://registry.npm.taobao.org腾讯镜像npm config set registry http://mirrors.cloud.tencent.com/npm

分布式事务_代码实现分布式事务_调皮的玩代码的博客-程序员秘密

一、分布式事务分布式事务是企业集成中的一个技术难点,也是每一个分布式系统架构中都会涉及到的一个东西,特别是在微服务架构中,几乎可以说是无法避免,本文就分布式事务来简单聊一下。二、数据库事务数据库事务的几个特性:原子性(Atomicity )、一致性( Consistency )、隔离性或独立性( Isolation)和持久性(Durabilily),简称就是ACID。数据库隔离级别...

Python 随机数验证码_西山枫叶的博客-程序员秘密

生成四个随机数的验证码直接上代码:这是生成验证码的方法:def validate_code(request): # 定义变量,用于画面的背景色、宽、高 # bgcolor = (random.randrange(256), random.randrange(256), random.randrange(256)) bgcolor = (255,255,255) ...

重剑无锋--小谈Scala编程_duanhengbin的博客-程序员秘密

本来调研Akka这个并发框架,不知不觉迷上了Scala编程已有一段时间。期间拜读Scala各种书籍,发现在国内实在太小众,Scala融合了面向对象及函数式的特点,有着强大的类型系统。外在来看Scala代码非常简洁并且有不输于动态语言的强大表现力,本文下面通过一个例子谈一谈。要实现这么一个小功能:    将任意int型转换为如下LED形式的字符串(三行) ' _ _ _ _ ...

ucloud子网介绍_chongwei2936的博客-程序员秘密

1.创建子网 假设分配到的网段是10.3.1.0(免费的) 2.买主机 "网络选择"选择私有网络并选择创建的子网(假设分配到内网IP为10.3.1.2) 3.创建一个路由器 假设分配到的内网IP是10.10.103.41(免费的) 我们绑定一个外网IP为118.118.118.118(这个...

推荐文章

热门文章

相关标签