zoukankan      html  css  js  c++  java
  • 并发-ScheduledThreadPoolExecutor

    参考:

    https://blog.csdn.net/qq_36299025/article/details/89491384

    todo

    https://blog.csdn.net/luanmousheng/article/details/77816412

    https://www.cnblogs.com/200911/p/6042417.html

    http://ifeve.com/33981-2/ 

    线程池之ScheduledThreadPool学习

    简介

    ScheduledThreadPool是一个能实现定时、周期性任务的线程池。

    创建方法

     public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
            return new ScheduledThreadPoolExecutor(corePoolSize);
        }


    这里创建了ScheduledThreadPoolExecutor,ScheduledThreadPoolExecutor继承自ThreadPoolExecutor,主要用于给定 延时之后的运行任务或定期处理任务。ScheduledThreadPoolExecutor的构造方法如下:

    public ScheduledThreadPoolExecutor(int corePoolSize) {
            super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
                  new DelayedWorkQueue());
        }

    ScheduledThreadPoolExecutor构造方法中最终调用的是父类ThreadPoolExecutor的构造方法;corePoolSize是传递进来的固定数值,maximumPoolSize的值是Integer.MAX_VALUE;DelayedWorkQueue是无界的,因此maximumPoolSize是无效的。

    execute方法执行

    在这里插入图片描述当执行ScheduledThreadPoolExecutor的scheduleAtFixedRate或scheduleWithFixedDelay方法,会向DelayedWorkQueue添加一个实现RunnableScheduledFuture接口的任务包装类ScheduledFutureTask,并检查运行的线程是否达到核心线程数corePoolSize。
    如果没有就新建线程,并启动。但并非立即执行任务,而是去DelayedWorkQueue中取任务包装类ScheduledFutureTask,然后再去执行任务;
    如果运行的线程达到了corePoolSize,就把任务添加到任务队列DelayedWorkQueue中;DelayedWorkQueue会将任务排序,先执行的任务放在队列的前面。
    任务执行完后,ScheduledFutureTask中的变量time改为下次要执行的时间,并放回到DelayedWorkQueue中。

  • 相关阅读:
    ipa在线下载安装(itms-services)
    linux环境下无文件执行elf
    Linux Running State Process ".so"、"code" Injection Technology
    VS2013本地C++单元测试框架
    vs的环境变量
    利用rundll32执行程序的函数执行程序
    动态so注入
    ELF运行时注入
    MailKit系列之转发电子邮件
    WPF实战之一 桌面消息框(右下角消息弹出框)
  • 原文地址:https://www.cnblogs.com/xuwc/p/14053654.html
Copyright © 2011-2022 走看看