Java中定时启动线程

这里提供两种在指定时间后启动线程的方法。一是通过java.util.concurrent.DelayQueue实现;二是通过java.util.concurrent.ScheduledThreadPoolExecuTor实现。

1. java.util.concurrent.DelayQueue

类DelayQueue是一个无界阻塞队列,只有在延迟期满时才能从中提取元素。它接受实现Delayed接口的实例作为元素。

<>Delayed.java

package java.util.concurrent;import java.util.*;public interface Delayed extends Comparable {   long getDelay(TimeUnit unit);}

getDelay()返回与此对象相关的剩余延迟时间,以给定的时间单位表示。此接口的实现必须定义一个 compareTo 方法,该方法提供与此接口的 getDelay 方法一致的排序。

DelayQueue队列的头部是延迟期满后保存时间最长的 Delayed 元素。当一个元素的getDelay(TimeUnit.NANOSECONDS) 方法返回一个小于等于 0 的值时,将发生到期。

2.设计带有时间延迟特性的队列

类DelayedTasker维护一个DelayQueue queue,其中DelayedTask实现了Delayed接口,并由一个内部类定义。外部类和内部类都实现Runnable接口,对于外部类来说,它的run方法是按定义的时间先后取出队列中的任务,而这些任务即内部类的实例,内部类的run方法定义每个线程具体逻辑。

这个设计的实质是定义了一个具有时间特性的线程任务列表,而且该列表可以是任意长度的。每次添加任务时指定启动时间即可。

DelayedTasker.java

package com.zj.timedtask;import static java.util.concurrent.TimeUnit.SECONDS;import static java.util.concurrent.TimeUnit.NANOSECONDS;import java.util.Collection;import java.util.Collections;import java.util.Random;import java.util.concurrent.DelayQueue;import java.util.concurrent.Delayed;import java.util.concurrent.ExecuTorService;import java.util.concurrent.ExecuTors;import java.util.concurrent.TimeUnit;public class DelayedTasker implements Runnable {   DelayQueue queue = new DelayQueue();   public void addTask(DelayedTask e) {    queue.put(e);   }   public void removeTask() {    queue.poll();   }   public Collection getAllTasks() {    return Collections.unmodifiableCollection(queue);   }   public int getTaskQuantity() {    return queue.size();   }   public void run() {    while (!queue.isEmpty())      try {        queue.take().run();      } catch (InterruptedException e) {        System.out.println("Interrupted");      }    System.out.println("Finished DelayedTask");   }   public static class DelayedTask implements Delayed, Runnable {    private static int counter = 0;    private final int id = counter++;    private final int delta;    private final long trigger;    public DelayedTask(int delayInSeconds) {      delta = delayInSeconds;      trigger = System.nanoTime() + NANOSECONDS.convert(delta, SECONDS);    }    public long getDelay(TimeUnit unit) {      return unit.convert(trigger - System.nanoTime(), NANOSECONDS);    }    public int compareTo(Delayed arg) {      DelayedTask that = (DelayedTask) arg;      if (trigger that.trigger)        return 1;      return 0;    }    public void run() {      //run all that you want to do      System.out.println(this);    }    public String toString() {      return "[" + delta + "s]" + "Task" + id;    }   }   public static void main(String[] args) {    Random rand = new Random();    ExecuTorService exec = ExecuTors.newCachedThreadPool();    DelayedTasker tasker = new DelayedTasker();    for (int i = 0; i < 10; i++)      tasker.addTask(new DelayedTask(rand.nextInt(5)));    exec.execute(tasker);    exec.shutdown();   }}

结果:

[0s]Task 1[0s]Task 2[0s]Task 3[1s]Task 6[2s]Task 5[3s]Task 8[4s]Task 0[4s]Task 4[4s]Task 7[4s]Task 9Finished DelayedTask

3. jav 自己打败自己的远远多于比别人打败的。

Java中定时启动线程

相关文章:

你感兴趣的文章:

标签云: