zoukankan      html  css  js  c++  java
  • 用java.util.concurrent包来实现高速缓存

    接口

    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();
         }
        }

       }
    }
    }

  • 相关阅读:
    Arr
    class4
    class3联大网页
    class33
    class3
    人机交换 NO 1书签
    大数据的框架与特点
    mapreduce排序
    mapreduce求平均数
    mapreduce去重
  • 原文地址:https://www.cnblogs.com/macula7/p/1960507.html
Copyright © 2011-2022 走看看