<dependency>     <groupId>org.quartz-scheduler</groupId>     <artifactId>quartz</artifactId>     <version>2.2.2</version> </dependency>

package com.rjzheng.delay1; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SchedulerFactory; import org.quartz.SimpleScheduleBuilder; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.impl.StdSchedulerFactory; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException;  public class MyJob implements Job {     public void execute(JobExecutionContext context)             throws JobExecutionException {         System.out.println("要去数据库扫描啦。。。");     }      public static void main(String[] args) throws Exception {         // 创建任务         JobDetail jobDetail = JobBuilder.newJob(MyJob.class)                 .withIdentity("job1", "group1").build();         // 创建触发器 每3秒钟执行一次         Trigger trigger = TriggerBuilder                 .newTrigger()                 .withIdentity("trigger1", "group3")                 .withSchedule(                         SimpleScheduleBuilder.simpleSchedule()                                 .withIntervalInSeconds(3).repeatForever())                 .build();         Scheduler scheduler = new StdSchedulerFactory().getScheduler();         // 将任务及其触发器放入调度器         scheduler.scheduleJob(jobDetail, trigger);         // 调度器开始调度任务         scheduler.start();     } }

要去数据库扫描啦。。。

其中Poll():获取并移除队列的超时元素，没有则返回空；take():获取并移除队列的超时元素，如果没有则wait当前线程，直到有元素满足超时条件，返回结果。

实现

定义一个类OrderDelay实现Delayed，代码如下

package com.rjzheng.delay2;  import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit;  public class OrderDelay implements Delayed {      private String orderId;     private long timeout;      OrderDelay(String orderId, long timeout) {         this.orderId = orderId;         this.timeout = timeout + System.nanoTime();     }      public int compareTo(Delayed other) {         if (other == this)             return 0;         OrderDelay t = (OrderDelay) other;         long d = (getDelay(TimeUnit.NANOSECONDS) - t                 .getDelay(TimeUnit.NANOSECONDS));         return (d == 0) ? 0 : ((d < 0) ? -1 : 1);     }      // 返回距离你自定义的超时时间还有多少     public long getDelay(TimeUnit unit) {         return unit.convert(timeout - System.nanoTime(), TimeUnit.NANOSECONDS);     }      void print() {         System.out.println(orderId+"编号的订单要删除啦。。。。");     } }

运行的测试Demo为，我们设定延迟时间为3秒

package com.rjzheng.delay2;  import java.util.ArrayList; import java.util.List; import java.util.concurrent.DelayQueue; import java.util.concurrent.TimeUnit;  public class DelayQueueDemo {      public static void main(String[] args) {               // TODO Auto-generated method stub               List<String> list = new ArrayList<String>();               list.add("00000001");               list.add("00000002");               list.add("00000003");               list.add("00000004");               list.add("00000005");               DelayQueue<OrderDelay> queue = new DelayQueue<OrderDelay>();               long start = System.currentTimeMillis();               for(int i = 0;i<5;i++){                   //延迟三秒取出                 queue.put(new OrderDelay(list.get(i),                           TimeUnit.NANOSECONDS.convert(3, TimeUnit.SECONDS)));                       try {                            queue.take().print();                            System.out.println("After " +                                     (System.currentTimeMillis()-start) + " MilliSeconds");                   } catch (InterruptedException e) {                       // TODO Auto-generated catch block                       e.printStackTrace();                   }               }           }    }

输出如下

00000001编号的订单要删除啦。。。。 After 3003 MilliSeconds 00000002编号的订单要删除啦。。。。 After 6006 MilliSeconds 00000003编号的订单要删除啦。。。。 After 9006 MilliSeconds 00000004编号的订单要删除啦。。。。 After 12008 MilliSeconds 00000005编号的订单要删除啦。。。。 After 15009 MilliSeconds

可以看到都是延迟3秒，订单被删除

优缺点

优点:效率高,任务触发时间延迟低。
缺点:(1)服务器重启后，数据全部消失，怕宕机
   (2)集群扩展相当麻烦
   (3)因为内存条件限制的原因，比如下单未付款的订单数太多，那么很容易就出现OOM异常
   (4)代码复杂度较高

(3)时间轮算法

思路

先上一张时间轮的图(这图到处都是啦)