使用DelayQueue 和 FutureTask 实现java中的缓存

使用DelayQueue、ConcurrentHashMap、FutureTask实现的缓存工具类。

DelayQueue 简介

DelayQueue是一个支持延时获取元素的无界阻塞队列。DelayQueue内部队列使用PriorityQueue来实现。队列中的元素必须实现Delayed接口，在创建元素时可以指定多久才能从队列中获取当前元素。只有在延迟期满时才能从队列中提取元素。

DelayQueue非常有用，可以将DelayQueue运用在以下应用场景。

1. 缓存系统的设计：可以用DelayQueue保存缓存元素的有效期，使用一个线程循环查询
   DelayQueue，一旦能从DelayQueue中获取元素时，表示缓存有效期到了。
2. 定时任务调度：使用DelayQueue保存当天将会执行的任务和执行时间，一旦从
   DelayQueue中获取到任务就开始执行，比如TimerQueue就是使用DelayQueue实现的。

ConcurrentHashMap和FutureTask，详见以下：

1. http://www.jianshu.com/p/d10256f0ebea
2. FutureTask 源码分析

缓存工具类实现

1. 支持缓存多长时间，单位毫秒。
2. 支持多线程并发。
   比如：有一个比较耗时的操作，此时缓冲中没有此缓存值，一个线程开始计算这个耗时操作，而再次进来线程就不需要再次进行计算，只需要等上一个线程计算完成后（使用FutureTask）返回该值即可。

import java.util.concurrent.Callable;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;public class CacheBean<V> {// 缓存计算的结果private final static ConcurrentMap> cache = new ConcurrentHashMap<>();// 延迟队列来判断那些缓存过期private final static DelayQueue> delayQueue = new DelayQueue<>();// 缓存时间private final int ms;static {// 定时清理过期缓存Thread t = new Thread() {@Overridepublic void run() {dameonCheckOverdueKey();}};t.setDaemon(true);t.start();}private final Computable c;/*** @param c Computable*/public CacheBean(Computable c) {this(c, 60 * 1000);}/*** @param c Computable* @param ms 缓存多少毫秒*/public CacheBean(Computable c, int ms) {this.c = c;this.ms = ms;}public V compute(final String key) throws InterruptedException {while (true) {//根据key从缓存中获取值Future f = (Future) cache.get(key);if (f == null) {Callable eval = new Callable() {public V call() {return (V) c.compute(key);}};FutureTask ft = new FutureTask<>(eval);//如果缓存中存在此可以，则返回已存在的valuef = (Future) cache.putIfAbsent(key, (Future