摘自<<JAVA并發(fā)編程實戰(zhàn)>>
洋縣ssl適用于網(wǎng)站、小程序/APP、API接口等需要進行數(shù)據(jù)傳輸應用場景,ssl證書未來市場廣闊!成為成都創(chuàng)新互聯(lián)的ssl證書銷售渠道,可以享受市場價格4-6折優(yōu)惠!如果有意向歡迎電話聯(lián)系或者加微信:13518219792(備注:SSL證書合作)期待與您的合作!
public interface Computable<A, V> {
V comput(A arg);
}
import java.util.concurrent.*;/**
* 構(gòu)建高效可申縮的結(jié)果緩存
* <p>
* author: shiruiqiang
* time: 31/01/2017 23:11
**/public class Memoizer<A, V> implements Computable<A, V>{ private final ConcurrentHashMap<A, Future<V>> cache = new ConcurrentHashMap<A, Future<V>>(); private Computable<A, V> c; public Memoizer(Computable c) { this.c = c;
} public V comput(A arg) { while(true) {
Future<V> f = cache.get(arg); if (f == null) { // 檢查是緩存中是否已經(jīng)存在,如果沒有就創(chuàng)建
Callable<V> task = new Callable<V>() {
@Override public V call() throws Exception { return c.comput(arg);
}
};
FutureTask<V> ft = new FutureTask(task);
f = cache.putIfAbsent(arg, ft); // 原子操作,不會重復計算 if (f == null) { // 如果緩存中原來沒有這個結(jié)果則執(zhí)行任務計算結(jié)果
f = ft;
ft.run();
}
} try {
return f.get(); // 阻塞,等待結(jié)果.如果已經(jīng)在緩存中則不會阻塞
} catch(CancellationException e) {
cache.remove(arg, f);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
上述代碼有多方面好處
1:計算與緩存隔離,解偶
2:線程安全
3:支持并發(fā)
4:并發(fā)時不會重復計算,高效
網(wǎng)站名稱:構(gòu)建高效可申縮的結(jié)果緩存
當前鏈接:http://www.chinadenli.net/article4/iiesoe.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站內(nèi)鏈、ChatGPT、自適應網(wǎng)站、App開發(fā)、定制開發(fā)、網(wǎng)站設計
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)