java ScheduledFuture getDelay返回负值 - 腾讯云开发者社区

之前写 Java 定时任务用到了 ScheduledExecutorService，自己没有思路来实现定时任务的功能，所以十分好奇其底层代码的实现，于是乎就去翻看源码，在这过程中还发现了无处不在的... {} // Future 是异步获取结果，和 Runnable 对比 public interface ScheduledFuture extends Delayed, Future<V...* * @param 时间单位 * @return 剩余延迟时间，0或负值表示时间已经过去 */ long getDelay(TimeUnit unit...); } 3.2 ScheduledFutureTask ScheduledFutureTask 的构造函数入参有 Runnable、result、ns：分别是延迟任务、Future 返回、延迟时间...name, long delayTime) { this.name = name; this.delayTime = delayTime; } // 返回剩余时间

6402 0

聊聊flink的ScheduledExecutor

/java/util/concurrent/Executor.java public interface Executor { /** * Executes the given command...Executor，它定义了schedule、scheduleAtFixedRate、scheduleWithFixedDelay方法，其中schedule方法可以接收Runnable或者Callable，这些方法返回的都是...flink-release-1.7.2/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledExecutorServiceAdapter.java...(TimeUnit.NANOSECONDS) - o.getDelay(TimeUnit.NANOSECONDS); return (diff < 0L) ?...Executor，它定义了schedule、scheduleAtFixedRate、scheduleWithFixedDelay方法，其中schedule方法可以接收Runnable或者Callable，这些方法返回的都是

9874 0

您找到你想要的搜索结果了吗？

是的

没有找到

Math.abs()求绝对值返回负值BUG分享

近期在推进代码质量的过程中，发现一个隐藏的知识点，就是Math.abs()求一个int数据的绝对值的时候会出现返回结果为负值的BUG。...如果随机数生成器返回的数字为Integer.MIN_VALUE，则结果也将为负（因为Math.abs（Integer.MIN_VALUE）== Integer.MIN_VALUE）。

1.2K1 0

Java中调度线程池ScheduledThreadPoolExecutor原理探究

一、前言前面讲解过Java中线程池ThreadPoolExecutor原理探究，ThreadPoolExecutor是Executors中一部分功能，下面来介绍另外一部分功能也就是ScheduledThreadPoolExecutor...ClassDiagram1.jpg Executors其实是个工具类，里面提供了好多静态方法，根据用户选择返回不同的线程池实例。...command == null || unit == null) throw new NullPointerException(); //装饰任务，主要实现public long getDelay...49541d720d5b 修饰后把当前任务修饰为了delay队列所需元素，下面看下元素的两个重要方法：过期时间计算 //元素过期算法，装饰后时间-当前时间，就是即将过期剩余时间 public long getDelay...(TimeUnit.NANOSECONDS) - other.getDelay(TimeUnit.NANOSECONDS)); return (d == 0) ?

7023 1

线程池ScheduledThreadPoolExecutor源码解析

ScheduledThreadPoolExecutor概述我们在上一篇学习了ThreadPoolExecutor的实现原理：Java并发包源码学习系列：线程池ThreadPoolExecutor源码解析...ScheduledFutureTask是一个具有返回值的任务，继承自FutureTask。...getDelay获取元素剩余时间，也就是当前任务还剩多久过期，【剩余时间 = 到期时间 - 当前时间】。...public ScheduledFuture<?...true，否则返回false return ran && s == NEW; } 如果该方法返回true，将会调用setNextRunTime()设置下一次的运行时间，接着调用

1595 0

ScheduledThreadPoolExecutor原理探究

Executors其实是个工具类，里面提供了好多静态方法，根据用户选择返回不同的线程池实例。...过期时间计算 //元素过期算法，装饰后时间-当前时间，就是即将过期剩余时间 public long getDelay(TimeUnit unit) { return unit.convert(time...(TimeUnit.NANOSECONDS) - other.getDelay(TimeUnit.NANOSECONDS)); return (d == 0) ?...public ScheduledFuture<?...public ScheduledFuture<?

1.4K10 0

Java 线程池深入分析

作者疼蛋之丸来源 https://www.jianshu.com/p/5d5198b434a2 续上节《Java 线程线程池初探》四、ScheduledThreadPoolExecutor解析...sft); sft.outerTask = t; delayedExecute(t); return t; } public ScheduledFuture...callable } 对于后两个方法，区别仅仅在于period的，scheduleWithFixedDelay对参数进行了操作，将原来的时间变为负数了，而后面在计算下次被调度的时间的时候会根据这个参数的正负值来分别处理...(NANOSECONDS) - other.getDelay(NANOSECONDS); return (diff < 0) ?...需要更多更专业的知识类帮我理解更为底层的内容，当然，为了更进一步理解线程池的实现细节，首先需要对线程间通信有足够的把握，其次是要对各种数据结构有清晰的认识，比如队列、优先级队列、堆等高级的数据结构，以及java

3793 0

Java并发之ScheduledThreadPoolExecutor在Executor中延时执行任务在Executor中周期的执行任务

; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; public...java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; public class Main {...System.out.println("Main start at :" + new Date()); Task task = new Task("task"); ScheduledFuture...); for(int i=0;i<10;i++) { System.out.println("Main: Delay: " + result.getDelay...scheduleAtFixedRate方法会返回宇哥ScheduledFuture对象，这个对象扩展自Future接口，这是一个参数化的类型接口，必须指定类型，由于任务是Runnable对象，没有返回值

1.5K1 0

ScheduledExecutorService 接口

这两个方法都将返回一个ScheduledExecutorService线程池对象。...schedule()方法用于创建并执行给定的延迟的任务，返回的ScheduledFuture对象可以取消执行，或检查执行状态。...scheduled(commad,date.getTime() -System.currentTimeMills,TimeUnit.MILLISECONDS) ScheduledFuture...接口 ScheduledExecutorService接口的4个方法都将返回ScheduledFuture对象，ScheduledFuture也是一个接口，他从Delay和Future...该接口的getDelay方法用于获得延迟时间，get()方法用于获得操作结果，cancel()方法用于取消一个任务。

6592 0

java数组返回元素位置_把返回值用数组形式返回java

import java.util.Scanner; import javax.xml.soap.SAAJResult; /** * @author 大杨 *@date 2019年8月13日下午3:...public static void main(String[] args) { Scanner input=new Scanner(System.in); //初始化数组,遍历数组,找到返回下标...,未找到返回-1 int searchNum=-1; int [] search=new int[]{18,15,64,34,48,31,85,95,17,25}; System.out.print

2.1K1 0

线程池底层原理详解与源码分析（补充部分---ScheduledThreadPoolExecutor类分析）

triggerTime(delay, unit), sequencer.getAndIncrement())); delayedExecute(t); return t; } public ScheduledFuture...triggerTime(delay, unit), sequencer.getAndIncrement())); delayedExecute(t); return t; } public ScheduledFuture...= decorateTask(command, sft); sft.outerTask = t; delayedExecute(t); return t; } public ScheduledFuture...> task) { //如果处于运行状态返回true if (!...(NANOSECONDS) - other.getDelay(NANOSECONDS); return (diff < 0) ?

2012 0

高并发之——深度解析ScheduledThreadPoolExecutor类的源代码

public ScheduledFuture<?...public ScheduledFuture<?...public ScheduledFuture<?...< x.sequenceNumber) return -1; else return 1; } long diff = getDelay...(NANOSECONDS) - other.getDelay(NANOSECONDS); return (diff < 0) ?

4012 0

几种定时任务（Timer、TimerTask、ScheduledFuture）的退出—结合真实案例【JAVA并发】

e.toString()); } } } 通过scheduleAtFixedRate接口来调用（设置时间间隔和且第一次执行的延迟时间） scheduledFuture...scheduledFuture.isCancelled()) { try { long currentFileSize = Files.size...} } } } 通过scheduleAtFixedRate接口来调用（设置时间间隔和且第一次执行的延迟时间），并且将结果返回给...ScheduledFuture scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(new ScheduledUpdateTrafficForensics...(true)后可能不能成功结束定时任务，所以必须通过手动调用isCancelled()来判断是否被cancle（调用cancel后，再调用isCancelled() 【一定会返回true】）掉了，然后退出任务

1.6K2 1

五十、Ribbon的LoadBalancer五大组件之：ServerListUpdater

final long initialDelayMs; private final long refreshIntervalMs; // 继承自Futrue，在Futrue的基础上增加getDelay...(TimeUnit unit)方法：还有多久执行任务 // ScheduledExecutorService提交任务时返回它 // ScheduledThreadPoolExecutor是带有线程池功能的执行器...isActive.get()) { if (scheduledFuture !...(true); } // 为何返回String？...返回Date不香吗？

1.9K1 0

【原创】Java并发编程系列35 | ScheduledThreadPoolExecutor定时器

public ScheduledFuture<?...* @param callable 实现Callable接口的任务，ScheduledFuture.get()可获取任务结果 */ public ScheduledFuture...(NANOSECONDS) - other.getDelay(NANOSECONDS); return (diff < 0) ?...public ScheduledFuture<?...public ScheduledFuture<?

7611 0

Android中的线程

Java是单继承的，你继承了Thread类再也无法继承别的类。 Java虽然是单继承但是可以实现多接口的，即使你实现Runnable，你也可以实现别的接口。...返回false。 * 当此方法调用时此任务尚未开始，则此任务不会被运行。返回true。...* 此方法返回后，对{@link #isDone}的后续调用将始终返回{@code true}。...代表一个未完成的任务，可以通过get()获取null，还可以通过getDelay()获取剩余延迟时间 * @throws RejectedExecutionException if the...* @return a ScheduledFuture 可以通过get() 拿到结果，可以通过getDelay() 获取剩余延迟时间； * @throws RejectedExecutionException

1.4K14 0

自己动手系列-延迟队列

* @param unit 时间单位 * @return 剩余的时间; 零值或负值表示早已过期 */ long getDelay(TimeUnit unit);...该类是Java Collections Framework的成员。...在Java中，BlockingQueue的接口位于java.util.concurrent 包中(在Java5版本开始提供)，由上面介绍的阻塞队列的特性可知，阻塞队列是线程安全的。...在这种情况下，Java的PriorityQueue(优先队列)会很有帮助。 PriorityQueue类在Java1.5中引入并作为 Java Collections Framework 的一部分。...* * 返回与此对象相关的剩余延迟时间，以给定的时间单位表示 * * 这个方法会在CDelayQueue中被调用，通过对该方法的返回值的判断，来决定一个定时任务是否到时

2.8K12 0

(juc系列)scheduledthreadpoolexecutor源码阅读

前言这是Java中常用的另外一个线程池，主要用于实现任务的延迟执行及周期性执行. 听起来与Timer很相似，但是比Timer更加健壮，灵活一些。...(NANOSECONDS) - other.getDelay(NANOSECONDS); return (diff < 0) ?...如果队首的元素，还没到执行的时间，就返回Null.拒绝弹出....仅延迟执行一次 public ScheduledFuture<?...public ScheduledFuture<?

2182 0

周期性线程池

sequenceNumber < x.sequenceNumber) return -1; else return 1; } long diff = getDelay...(NANOSECONDS) - other.getDelay(NANOSECONDS); return (diff < 0) ?...方法的执行步骤： 1、如果线程池是shundown状态不支持处理新任务，直接取消任务，否则步骤2； 2、如果不是周期性任务，直接调用ScheduledFutureTask的run方法执行，会设置执行结果，然后直接返回...，否则步骤3； 3、如果是周期性任务，调用ScheduledFutureTask的runAndset方法执行，不会设置执行结果，然后直接返回，否则执行步骤4和步骤5； 4、计算下一次执行该任务的时间；...public ScheduledFuture<?

8214 0

重新说说Redis实现分布式公平可重入锁的实现，这次具体说说异步唤醒机制，这次带上QPS检测

;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.ConcurrentLinkedQueue;import...;import java.util.concurrent..../ 存在但不是自己的锁 " return redis.call('pttl',KEYS[1]);\n" + // 返回剩余时间...;import java.util.concurrent....6379 timeout: 5000 lettuce: pool: max-active: 100 # 连接池最大连接数（使用负值表示没有限制

68411 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

Java 多线程定时器分析

聊聊flink的ScheduledExecutor

Math.abs()求绝对值返回负值BUG分享

Java中调度线程池ScheduledThreadPoolExecutor原理探究

线程池ScheduledThreadPoolExecutor源码解析

ScheduledThreadPoolExecutor原理探究

Java 线程池深入分析

Java并发之ScheduledThreadPoolExecutor在Executor中延时执行任务在Executor中周期的执行任务

ScheduledExecutorService 接口

java数组返回元素位置_把返回值用数组形式返回java

线程池底层原理详解与源码分析（补充部分---ScheduledThreadPoolExecutor类分析）

高并发之——深度解析ScheduledThreadPoolExecutor类的源代码

几种定时任务（Timer、TimerTask、ScheduledFuture）的退出—结合真实案例【JAVA并发】

五十、Ribbon的LoadBalancer五大组件之：ServerListUpdater

【原创】Java并发编程系列35 | ScheduledThreadPoolExecutor定时器

Android中的线程

自己动手系列-延迟队列

(juc系列)scheduledthreadpoolexecutor源码阅读

周期性线程池

重新说说Redis实现分布式公平可重入锁的实现，这次具体说说异步唤醒机制，这次带上QPS检测

扫码

相关资讯

热门标签

活动推荐

运营活动

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐