消息队列多线程处理日志

package com.hangyjx.common.log; import java.util.Map; import java.util.Queue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * 日志队列工厂 * * * */ public class LogQueueFactory { //线程执行器:用于生产、消费线程调度 private final ExecutorService executorService = Executors.newFixedThreadPool(5); //工厂单例 private static final LogQueueFactory instance = new LogQueueFactory(); //日志队列 private final Queue<Map<String,Object>> logQueue = new LogQueue<Map<String,Object>>(); //生产监听器:入列时调度消费线程 private final LogQueueListener logQueueListener = new LogQueueListener(); private LogQueueFactory(){ } public static LogQueueFactory getInstance(){ return instance; } public ExecutorService getExecutorService() { return executorService; } public Queue<Map<String, Object>> getLogQueue() { return logQueue; } public LogQueueListener getLogQueueListener() { return logQueueListener; } }