利用java concurrent 包实现日志写数据库的并发处理

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.LinkedBlockingDeque;

public class LogManager implements Runnable {
    //定义缓存数据结构，支持并发操作
    private static LinkedBlockingDeque<ActionLog> list = new LinkedBlockingDeque<ActionLog>();
    static{
        //创建并启动线程，该线程实现日志的入库
        new Thread(new LogManager()).start();
    }
    public static void addActionLog(ActionLog log) {
        list.add(log);
    }

    @Override
    public void run() {
        List<ActionLog> items = new ArrayList<ActionLog>();
        while (true) {
            //从缓存中取出1条日志，但不从缓存中删除。用于检查队列中是否有数据
            ActionLog item = list.peek();
            if (item == null && items.size() > 0) {
                //item为null说明缓存中没有日志了，这时如果临时队列items中有记录，就可以批量入库了
                work(items);
            }
            //从缓存中取出并删除最前面的日志，如果无数据，在堵塞
            ActionLog result = deleteItem();
            //将取出的记录放到临时队列中
            items.add(result);
        }
    }

    private ActionLog deleteItem() {
        ActionLog result = null;
        try {
            //取出并删除最前面的一条数据，如果缓存中无数据，则堵塞住
            result = list.takeFirst();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return result;
    }

    private void work(List<ActionLog> items) {
        //TODO 完成入库。这里代码没有提供
        //入库后删除临时队列中记录
        items.clear();
    }

}