private Map<String,String> cache = new HashMap<String,String>();//这里只是一个普通的map,所以需要读写锁来保证原子性,而java并发库已经帮助我们做到了这一点
private ReadWriteLock rwl = new ReentrantReadWriteLock();
public Object getData(String key){
rwl.readLock().lock();
Object value = null;
try{
value = cache.get(key);
if(value == null){ //如果没读到,释放读锁,加写锁
rwl.readLock().unlock();
rwl.writeLock().lock();
try{
value = cache.get(key);
if(value==null){ // 防止重复写,只有value为空的时候才能写,
//比如有两个线程到了rwl.writeLock().lock();,第一个线程先拿到写锁,写完后,第二个线程就不应该去写了,所以这里对第二个线程要验证下
value = "aaaa";//实际失去queryDB();//这个地方可能需要很长时间,这里是把计算完后的结果传给cache,后面把这里改进了
cache.put(key, value);
}
}finally{
rwl.writeLock().unlock();
}
rwl.readLock().lock();
}
}finally{
rwl.readLock().unlock();
}
return value;
}
高性能的cache
interface Computable<A,V>{
V compute(A arg) throws InterruptedException;
}
class Memoizer<A,V> implements Computable<A,V>{
//A代表输入,Future<V>代表输出的结果
private final ConcurrentMap<A, Future<V>> cache=new ConcurrentHashMap<A, Future<V>>();
//使用Future的好处是,如果有某个线程已经开始在做这件事情,但是还没拿到结果,那么其他线程就不会去重复做这件事情了,只需要等待那个线程的结果即可
//private final ConcurrentMap<A, V> cache2=new ConcurrentHashMap<A, V>();
private final Computable<A,V> c;
public Memoizer(Computable<A,V> c){
this.c=c;
}
@Override
public V compute(final A arg) throws InterruptedException {
while(true){
Future<V> f= cache.get(arg); //判断计算是否已经开始 ,区别于cache2,他判断的是一个结果是否已经完成
if(f == null){//如果计算还未开始
//定制一个任务
Callable<V> eval = new Callable<V>() {
@Override
public V call() throws Exception {
// TODO Auto-generated method stub
return c.compute(arg);
}
};
FutureTask<V> ft = new FutureTask<V>(eval);//FutureTask就是一线程,可以run Callable的线程
//注册到map中
f= cache.putIfAbsent(arg, ft);
if(f==null){//再次判断,防止两个线程重复做同样的事情
f=ft;
ft.run();
}
}
try{
return f.get();//其他线程在计算结果,所以此线程本事就不需要去拿结果了,只需要等待其他线程返回结果即可
}catch (CancellationException e) {
cache.remove(arg,f);
}catch(Exception e){
}
}
}
分享到:
相关推荐
6:使用状态模式 观察者模式更好的处理多线程 最初的想法:网络优化开发框架 (移除任务未完成) 网络稳定,系统运行稳定性,大内存消耗稳定,长时间运行稳定性 (旧的系统症结所在) 开启过多线程,导致系统...
在Java编程领域,多线程开发是不可或缺的一部分,特别是在面试环节,面试官常常会通过考察开发者对多线程的理解和实战经验来评估其技术水平。JavaConcurrent是Java平台提供的高级并发API,它使得多线程编程更加高效...
### Android中的线程与多线程技术详解 在Android开发中,线程和多线程技术是实现应用程序高效运行的关键所在。本篇文章将详细介绍Android线程的基础知识、使用方法及同步机制等内容。 #### 一、Android线程概述 ...
在多线程编程中,事件驱动模型允许线程在特定事件发生时进行响应,如数据加载完成或缓存更新。通过订阅和触发事件,开发人员可以创建异步行为,提高程序的响应性和效率。 接着是"CommonThread.txt",这可能是通用...
这款下载器具备多线程、断点续传和加密视频下载缓存等高级功能,极大地提升了用户下载和管理M3U8视频的体验。 首先,我们来详细了解一下多线程下载。多线程技术是将一个大任务拆分成多个小任务,同时由多个处理器或...
在Qt框架中,SQLite...总之,Qt中SQLite的多线程操作需要谨慎处理,遵循良好的并发编程实践,以确保数据一致性、安全性和应用程序的稳定性。正确理解和应用上述原则将有助于避免潜在的问题,提升多线程应用的性能。
Java中的多线程和线程同步是编程中关键的概念,特别是在处理并发操作和优化性能时。下面我们将深入探讨这些主题。 首先,线程是程序执行的独立路径,它允许一个程序同时执行多个任务。在Java中,我们有两种方式创建...
多线程能够改善用户体验,比如在下载文件的同时进行其他操作,或者在后台执行耗时任务而不会阻塞用户界面。 然而,多线程也带来了挑战,如线程安全问题。当多个线程共享同一资源时,可能会出现竞态条件、死锁或活锁...
### 多线程程序中的原子操作 #### 一、引言 在多线程编程中,原子操作是一个至关重要的概念。原子操作指的是不可再分割的操作,即在一个操作执行的过程中不会被其他线程打断。这对于保证多线程程序的正确性和避免...
在iOS开发中,多线程是一项关键的技术,用于提高应用程序的响应速度和用户体验。当我们谈论“OC-多线程-上下文切换”时,我们实际上是在讨论Objective-C中多线程环境下的一个核心概念。上下文切换是操作系统调度线程...
本项目通过使用WriteableBitmap和多线程技术,结合双缓存策略,实现了高效的绘图性能。下面将详细介绍这些关键知识点。 1. **WriteableBitmap**: WriteableBitmap是WPF中用于直接像素操作的类,它允许开发者以编程...
### Java多线程文章系列知识点概述 #### 一、Java多线程编程详解 ##### 1. 理解多线程 - **定义**: 多线程是一种机制,允许程序中并行执行多个指令流,每个指令流称为一个线程。 - **特点**: - 线程拥有独立的...
综上所述,构建秒杀系统的关键在于合理利用多线程技术处理高并发,通过缓存和并发控制策略保证系统的稳定性和数据的一致性。同时,数据库设计和优化也是不可或缺的部分,确保在高负载下系统仍能高效运行。
在Java编程中,多线程导入Excel数据是一项常见的任务,特别是在大数据处理和高并发场景下。这个场景通常涉及到性能优化和资源管理,以确保系统稳定性和数据一致性。下面将详细阐述多线程导入Excel数据的核心知识点。...
在处理大量图像或需要快速响应时间的应用场景中,多线程并发识别可以显著提升效率。以下将详细介绍如何利用Tesseract OCR实现多线程并发识别,以及可能涉及的相关技术点。 首先,理解Tesseract OCR的基本工作原理是...
本文将结合名为"SemQueue"的项目,深入探讨如何在Windows和Linux这两个主流操作系统平台上实现一个跨平台的、支持多线程的缓存队列。 首先,我们来看"SemQueue"的核心组件——"SemQueue.h"。这个头文件通常包含了...
5. **IO与逻辑分离**:在多线程环境中,将I/O密集型操作(如网络通信)和CPU密集型操作(如逻辑计算)分离,可以提高系统的并发性能。例如,网络模块收到消息后立即返回,由专门的逻辑线程处理这些消息,避免了I/O...
- `volatile`关键字:确保多线程环境下的变量读取始终是最新的值,避免缓存导致的问题。 - `Interlocked`类:提供原子操作,如增加、减小、交换等,避免竞态条件。 5. **异步编程模型**:C#从4.0版本开始引入了...