java定时任务代码实现 java定时任务schedule

java怎么用定时任务实现失效

1、ZSet 实现方式

通过 ZSet 实现定时任务的思路是java定时任务代码实现，将定时任务存放到 ZSet 集合中，并且将过期时间存储到 ZSet 的 Score 字段中，然后通过一个无线循环来判断当前时间内是否有需要执行的定时任务，如果有则进行执行，具体实现代码如下java定时任务代码实现：

import redis.clients.jedis.Jedis;

import utils.JedisUtils;

import java.time.Instant;

import java.util.Set;

public class DelayQueueExample {

private static final String _KEY = "DelayQueueExample";

public static void main(String[] args) throws InterruptedException {

Jedis jedis = JedisUtils.getJedis();

// 30s 后执行

long delayTime = Instant.now().plusSeconds(30).getEpochSecond();

jedis.zadd(_KEY, delayTime, "order_1");

// 继续添加测试数据

jedis.zadd(_KEY, Instant.now().plusSeconds(2).getEpochSecond(), "order_2");

jedis.zadd(_KEY, Instant.now().plusSeconds(2).getEpochSecond(), "order_3");

jedis.zadd(_KEY, Instant.now().plusSeconds(7).getEpochSecond(), "order_4");

jedis.zadd(_KEY, Instant.now().plusSeconds(10).getEpochSecond(), "order_5");

// 开启定时任务队列

doDelayQueue(jedis);

}

/**

* 定时任务队列消费

* @param jedis Redis 客户端

*/

public static void doDelayQueue(Jedis jedis) throws InterruptedException {

while (true) {

// 当前时间

Instant nowInstant = Instant.now();

long lastSecond = nowInstant.plusSeconds(-1).getEpochSecond();

// 上一秒时间

long nowSecond = nowInstant.getEpochSecond();

// 查询当前时间的所有任务

Set data = jedis.zrangeByScore(_KEY, lastSecond, nowSecond);

for (String item : data) {

// 消费任务

System.out.println("消费：" + item);

}

// 删除已经执行的任务

jedis.zremrangeByScore(_KEY, lastSecond, nowSecond);

Thread.sleep(1000); // 每秒查询一次

}

}

}

登录后复制



2、键空间通知

我们可以通过 Redis 的键空间通知来实现定时任务，它的实现思路是给所有的定时任务设置一个过期时间，等到java定时任务代码实现了过期之后，我们通过订阅过期消息就能感知到定时任务需要被执行java定时任务代码实现了，此时我们执行定时任务即可。

默认情况下 Redis 是不开启键空间通知的，需要我们通过 config set notify-keyspace-events Ex 的命令手动开启，开启之后定时任务的代码如下

相关问答

Q1: 在Java中如何设置一个定时任务的代码应该怎么写？

指定定时任务java定时任务代码实现的代码如下：

public void schedule(TimerTask task,Date time)

比如,我们希望定时任务2006年7月2日0时0分执行,只要给第二个参数传一个时间设置为2006年7月2日0时0分java定时任务代码实现的Date对象就可以java定时任务代码实现了.

有一种情况是,可能我们java定时任务代码实现的程序启动java定时任务代码实现的时候,已经是2006年7月3日了,这样的话,程序一启动,定时任务就开始执行了.

schedule最后一个重载的方法是

public void schedule(TimerTask task,Date firstTime,long period)

既然号称是定时任务,我们肯定希望由我们来指定任务指定的时间,显然上面的方法就不中用了,因为我们不知道程序什么时间开始运行,就没办法确定需要延时多少.没关系,schedule四个重载的方法还没用完呢.用下面这个就OK了。

Q2: JAVA实现定时任务的几种方式

Java 基本java定时任务代码实现的定时任务java定时任务代码实现，总结方法有三种java定时任务代码实现：

1   创建一个thread，然后让它在while循环里一直运行着，通过sleep方法来达到定时任务的效果java定时任务代码实现；

2   用Timer和TimerTask与第一种方法相比有如下好处：

当启动和去取消任务时可以控制

第一次执行任务时可以指定你想要的delay时间

3   用ScheduledExecutorService是从的java.util.concurrent里，做为并发工具类被引进的，这是最理想的定时任务实现方式，相比于上两个方法，它有以下好处：

相比于Timer的单线程，它是通过线程池的方式来执行任务的

可以很灵活的去设定第一次执行任务delay时间

提供了良好的约定，以便设定执行的时间间隔

java定时任务代码实现的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于java定时任务schedule、java定时任务代码实现的信息别忘了在本站进行查找喔。