ScheduledExecutorService 接口[通俗易懂]

ScheduledExecutorService 接口[通俗易懂]newScheduledThreadPool()或者newSingleThreadScheduled-Executor()方法:延迟执行、周期性执行的执行器如果想在某一段时间之后执行线程操作,或者周期性地重复执行线程操作,则可以使用工厂类Executors的newScheduledThreadPool()方法或者newSingleThreadSche…

大家好,又见面了,我是你们的朋友全栈君。

newScheduledThreadPool() 或者newSingleThreadScheduled-Executor()方法:延迟执行、周期性执行的执行器
        
            如果想在某一段时间之后执行线程操作,或者周期性地重复执行线程操作,则可以使用工厂类Executors的newScheduledThreadPool()方法或者 newSingleThreadScheduled-Executor()方法。
            newScheduledThreadPool()方法使用给定数目的线程来调度执行任务,而newSingleThreadScheduledExecutor()方法在一个单独的线程中调度任务。
            这两个方法都将返回一个ScheduledExecutorService线程池对象。
        
        ScheduledExecutorService接口
        
        ScheduledExecutorService接口从ExecutorService接口继承而来,可用于在给定的延迟后运行的某个任务,或者周期性的执行某个任务。
            schedule()方法用于创建并执行给定的延迟的任务,返回的ScheduledFuture对象可以取消执行,或检查执行状态。scheduleAtFixedRate 和scheduleWithFixedDelay用于创建并执行一个周期性或者
            固定延迟任务,直到任务取消。
            在schedule()方法中,延迟时间一般大于0,但也允许取值为0或者负数(非周期性执行),在这种情况下,认为是立刻执行。
            TimeUnit 用于指明时间单位,时间都是相对的时间,而不是绝对的时间。例如,在某一个日期之后运行,则可以使用下面的语句。
            scheduled(commad,date.getTime() -System.currentTimeMills,TimeUnit.MILLISECONDS)
            
        ScheduledFuture接口
            ScheduledExecutorService接口的4个方法都将返回ScheduledFuture对象,ScheduledFuture也是一个接口,他从Delay和Future接口继承而来,表示一个延迟的、结果可接受的操作。
            该接口的getDelay方法用于获得延迟时间,get()方法用于获得操作结果,cancel()方法用于取消一个任务。

            demo  示例:
            
            监控一个设备的工作温度,当温度超过10°C后,每隔1s发出一次警告,如果连续发出10报警后,仍没有处理,则停止设备运行。

            分析 :设置两个线程,一个线程表示设备运行。一个线程监视设备运行,采用ScheduleAtFixedRate()方法来调度,当设备警告10次,采用取消cancel()或者shutdown()方法关闭设备。
            
            //设备线程类
            public class Machine implements Runnable{

                int temperature;
                Machine(int temperature){

                    this.temperature = temperature;
                }
                public void run(){

                    perform();
                    temperature++;
                    System.out.println(“机器的工作温度在升高,当前的温度:”+temperature);
                }
                private void perform(){

                    int temp = (int)(Math.random()*Integer.MAX_VALUE);
                    int sum = 0;
                    for(int i=0;i<temp;i++){

                        sum += i;
                    }
                }
                private int getTemperature(){

                    return temperature;
                }
            }
            
            //监控设备线程类
            public class Monitor implements Runnable{

                Machine machine;
                ScheduledExecutorService scheduler;
                 static int n = 0;
                
                Monitor(Machine machine,ScheduledExecutorService scheduler){

                    this.machine = machine;
                    this.scheduler = scheduler;
                }
                public void run(){

                    if(machine.temperature>=10){

                        System.out.println(“警告!机器温度过高。”);
                        n++;
                    }
                    if(n>10){

                        System.out.println(“提醒次数限制已到,禁止任务”);
                        scheduler.shutdown();
                    }    
                }    
            }
            
            //测试启动类
            public class Index{

                public static void main(String[] args){

                    ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
                    Machine machine = new Machine(0);
                    Monitor monitor = new Monitor(machine,scheduler);
                    scheduler.scheduleAtFixedRate(machine,1,2,TimeUnit.SECONDS);
                    scheduler.scheduleAtFixedRate(monitor,0,1,TimeUnit.SECONDS);
                }
            }

运行结果:

机器的工作温度在升高,当前的温度:1
机器的工作温度在升高,当前的温度:2
机器的工作温度在升高,当前的温度:3
机器的工作温度在升高,当前的温度:4
机器的工作温度在升高,当前的温度:5
机器的工作温度在升高,当前的温度:6
机器的工作温度在升高,当前的温度:7
机器的工作温度在升高,当前的温度:8
机器的工作温度在升高,当前的温度:9
机器的工作温度在升高,当前的温度:10
警告!机器温度过高。
警告!机器温度过高。
机器的工作温度在升高,当前的温度:11
警告!机器温度过高。
警告!机器温度过高。
机器的工作温度在升高,当前的温度:12
警告!机器温度过高。
警告!机器温度过高。
机器的工作温度在升高,当前的温度:13
警告!机器温度过高。
警告!机器温度过高。
机器的工作温度在升高,当前的温度:14
警告!机器温度过高。
警告!机器温度过高。
机器的工作温度在升高,当前的温度:15
警告!机器温度过高。
提醒次数限制已到,禁止任务

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/137075.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 线程池参数如何设置?

    线程池参数如何设置?前言着计算机行业的飞速发展,摩尔定律逐渐失效,多核CPU成为主流。使用多线程并行计算逐渐成为开发人员提升服务器性能的基本武器。J.U.C提供的线程池:ThreadPoolExecutor类,帮助开发人员管理线程并方便地执行并行任务。了解并合理使用线程池,是一个开发人员必修的基本功。线程池参数配置方案显得十分重要。一、参数设置的传统方案1.线程池中执行的任务性质。计算密集型的任务比较占cpu,所以一般线程数设置的大小等于或者略微大于cpu的核数;但IO型任务主要时间消耗在IO等待上,cpu压

  • Python基本数据类型

    Python基本数据类型一、简介Python基本数据类型一般分为:数字、字符串、列表、元组、字典、集合这六种基本数据类型。其中数字又包含整型(整型又包括标准整型、长整型(Python2.7及之前版本有))、浮点型、复数类

  • npm下载和使用(超详细)

    npm下载和使用(超详细)NPM(NodePackageManager)简称为Node包管理工具安装(首先我们需要安装Node)Mac如果没有安装Node可以使用mac的包管理神器HomeBrew进行安装,首先下载HomeBrew,接下来在终端执行以下命令brewinstallnode也可以选择去官网下载pkg安装包,记得下载长期稳定版,即LTS版windows可以在官网中选择windows相对应的版本,同样下载稳定版本,一步点击安装即可使用当下载好Node后我们就可以使用n..

    2022年10月28日
  • sublime 激活码【注册码】

    sublime 激活码【注册码】,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • Mac下设置Android源代码编译环境

    Mac下设置Android源代码编译环境

  • C#开发WebService实例和发布

    C#开发WebService实例和发布WebService是一种跨平台,独立于编程语言之外的通信技术,将其部署在服务器端,在网络内的所有设备都可以调用这个WebService。本文介绍用C#开发WebService实例以及其部署和调用。首先是一个简单的WebService工程的创建:1、创建一个asp.netweb应用程序,我这里起名字叫WebServiceTest2、创建一个空的模板3、然后给这个空项目添加web服务…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号