多例模式和数据统计

我们知道单例模式是多例模式的一个特例，在多例模式中多例类管理着自己的多个实例，自己初始化自己的实例并且向外界提供自己的实例。而且多例类 必须自己初始化自己，外界无法通过调用多例类的构造函数实例化一个多例类。
既然对多例模式有了一个大概的理解，那么现在就来看下多例类在一个具体的环境下的使用。
下面我们考虑一个统计数据的案例，在一个系统中，数据库中存储的数据量很大，数据每月都会以一定的速度增加，现在要的是针对每个月做一次统计，也就是现在 是9月份，那么8月份的统计在以后都会不变，但是如果我们现在要看9月份的统计，那应该是会变得也就是在9月份你今天看到的9月份的统计数据和明天看到的 统计数据时不一样的。这样我们第一次想到的可能就是当每次查询到来的时候我们通过sql语句进行一次统计，我们虎发现的是这样做每次的统计花费的时间（几 十秒）是难以忍受的，那么有没有什么好的办法了。
办法是要的就是把统计数据缓存起来，比如说把统计数据存储到一个文件中比如xml文件，那么下次请求到来的时候我们只要把xml中保存的数据返回给用户就可以啦。
现在的问题又要啦，既然是存储在一个文件中，那么什么时候生成这个文件，什么时候跟新这个文件了。哦，可能很简单那就是每次请求过来的时候如果文件不存在 就生成，如果过时来就跟新，但是我们先在来具体考虑下会发生什么。假设在XX时间有5个请求如果这个时候要生成这个文件那么也就是同时有5个线程在试图生 成这个文件，这个时候会发生什么我们是无法保证的。那么有没有什么好的方法来保证了。
现在我们来看把多例模式变化下，应用到这个环境中来。我们要求得是，当请求到来的时候，我们检查是否要跟新文件或者生成文件，如果要那么我们继续检查是否 已经有线程在跟新这个文件如果要我们只要把当前的请求线程放到等待队列中就可以啦，如果没有那么我们就生成这样的一个跟新线程并且把当前请求线程放在这个 线程的等待队列中。下面我们来看下具体代码的实现。
我们定义一个接口：

public interface INotify {
void finished(boolean flag);
}

 

这个接口用来当更新线程完成后用来唤醒等待线程。
另一个接口用来把当前请求线程加入到等待队列中：

public interface IWaitingAction extends Runnable {
void addNotifyObject(INotify notify);
}

 

现在我们来实现这个变种的实例类。

public class TopBookService implements IWaitingAction {
private LinkedList<INotify> list = null;
private String key;
private TopBookService(String key){this.key = key;}
private static Map<String, TopBookService> map = new HashMap<String, TopBookService>();
public static synchronized TopBookService getInstance(String key){
if(map.containsKey(key)){
return map.get(key);
}
TopBookService service = new TopBookService(key);
new Thread(service).start();
return service;
}
public synchronized void addNotifyObject(INotify notify) {
if(list == null){
list = new LinkedList<INotify>();
}
list.add(notify);
}
public void run() {   
//生成新的文件。
//在提示之前把service从池中删除 确保每个加入service等待队列中的任务都被提醒啦。
map.remove(key);
if(list != null){
for (INotify notify : list) {
notify.finished(true);
}
}
}
}

 

线面我们来看具体的Action中做了些什么：

public class BookTopAction extends BaseAction implements INotify {
private boolean finished = false;
public String bookTop()throws Exception{
initResult();
return "json";
}

protected void initResult(){
//判断文件是否需要跟新。
if(needUpdate(fileName)){
//如果要跟新，那么就跟新文件
updateXmlFile(fileName);
//等待更新的完成
while(!finished){
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
//解析文件并且生成返回结果

}
/**
* 跟新排行榜上前十的书本的xml文件
*
* @return
* @param fileName 被更新的文件名
*/
protected synchronized void updateXmlFile(String filename){
//如果有程序在更新xml文件，那么就直接返回不更新xml文件
TopBookService.getInstance(filename).addNotifyObject(this);
}
protected boolean needUpdate(String filename){
File file = new File(filename);
boolean flag = false;
//判断文件是否要更新或者生成
return flag;
}
public void finished(boolean flag) {
this.finished = flag;

}
}

 

=============================================================
转载请注明作者：liuhello（http://hi.baidu.com/liuqinglai ）