接口
public interface Computable<A,V> {
V compute(A args);
}
计算式很耗时间的话可以将结果缓存,缓存程序如下:
public class Memorizer<A, V> implements Computable<A, V> {
/*
* 该类主要功能是实现高速缓存,缓存计算结果
* 该类唯一的缺点在于判定f是否为null的时候接近完美
*
*/
//使用ConcurrentHashMap来缓存可以起到同步的作用,而Future可以避免重复工作(检查的时候都为空,同时计算)
private final ConcurrentHashMap<A, Future<V>> cache = new ConcurrentHashMap<A, Future<V>>();
private Computable<A,V> c;
public Memorizer(Computable<A, V> c) {
this.c = c;
}
public V compute(final A args) {
while (true) {
Future<V> f = cache.get(args);
if (f == null) {
Callable<V> eval = new Callable<V>() {
public V call() throws Exception {
return c.compute(args);
}
};
FutureTask<V> ft = new FutureTask<V>(eval);
f = cache.putIfAbsent(args, ft);
if (f == null) {
f = ft;
ft.run();
}
try {
return f.get();
} catch (InterruptedException e) {
cache.remove(args,f);
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
}
}