程序总是在两三天就报一次内存泄漏的异常,不知道是什么原因引起的,因为项目中有一个地方冲到队列,在队列中创建了很多的线程不知道是不是这个引起了。。。
public class GlobalVariables { public static ExecutorService pool = Executors.newFixedThreadPool(1000); public static BlockingQueue queue = new ArrayBlockingQueue(1000); public static Map map = new HashMap(); } public class AddQueues implements Runnable{ private Object obj; public AddQueues(Object obj) { this.obj = obj; } @Override public void run() { try { System.out.println("-------------"+obj); GlobalVariables.queue.put(obj); } catch (InterruptedException e) { e.printStackTrace(); } } } @Override public Map updateQueuePool(Map map) throws Exception { EntranceVisitCountDTO dto = new EntranceVisitCountDTO(); dto.setAdminUserId(Integer.parseInt(map.get("adminUserId").toString())); GlobalVariables.pool.submit(new AddQueues(dto)); Map param = new HashMap(); param.put("result", "yes"); return param; } /** * 定时将队列里的数据放到map中 */ @Scheduled(cron = "0/3 * * * * ?") public synchronized void updateVisitCountOfMap(){ try{ if(!GlobalVariables.queue.isEmpty()){ for(int i = 0; i < 100; i++){ Object obj = GlobalVariables.queue.take(); if(obj instanceof EntranceVisitCountDTO){ EntranceVisitCountDTO dto = (EntranceVisitCountDTO)obj; Integer visitCount = GlobalVariables.map.get(dto.getAdminUserId()); if(visitCount != null && GlobalVariables.map.size() <= 1000){ GlobalVariables.map.put(dto.getAdminUserId(), visitCount +1); }else if(GlobalVariables.map.size() > 1000){ visitDayCountService.updateEntranceShowCount(); }else{ GlobalVariables.map.put(dto.getAdminUserId(), 1); } } if(GlobalVariables.queue.isEmpty()){ break; } } } } catch (Exception e) { e.printStackTrace(); } } /** * 定时将map中的缓存数据同步入口 */ @Scheduled(cron = "0 0/10 * * * ?") public synchronized void updateEntranceShowCount(){ try{ visitDayCountService.updateEntranceShowCount(); } catch (Exception e) { e.printStackTrace(); } } @Transactional(rollbackFor = Exception.class) @Override public synchronized void updateEntranceShowCount() throws Exception { if(!GlobalVariables.map.isEmpty()){ for(Map.Entry entry : GlobalVariables.map.entrySet()){ String day = TimeUtils.getSpecifyDate(0, "yyyy-MM-dd"); VisitDayCount visitDayCount = (VisitDayCount)visitDayCountDao.getEntranceCountByEntranceInfoIdWithCreateDate(entry.getKey(), day, "VisitDayCount"); if(null == visitDayCount){ visitDayCount = new VisitDayCount(); visitDayCount.setNum(1); visitDayCount.setAdminUserId(entry.getKey()); visitDayCount.setVisitTime(day); visitDayCountDao.save(visitDayCount); }else{ visitDayCountDao.updateEntranceVistCount(entry.getKey(), entry.getValue()); } GlobalVariables.map.remove(entry.getKey()); } } }
你设置的线程池大小是1000个,没必要建这么多吧,可以先看下主机是几核几线程,建议调低一点。另外jvm中的xxs分配多大,这个是影响你在jvm中能开多少线程的。在核查xmx的大小。
'unable to create new native thread'很少有这种OOM,一定是代码那里不断的new Thread()造成的。改成线程池吧。
这段代码的入口应该是updateQueuePool方法,这个方法会生成DTO,然后创建新的job来吧DTO放到queue里面去,而这个queue的消费者是在updateVisitCountOfMap,这个方法每3秒钟消费100个DTO,如果调用updateQueuePooll方法的频率大于消费的频率的话,OOM是早晚的事情
GlobalVariables.map也是类似的问题,每3秒放入最多100个对象,但是每10分钟消费。
GlobalVariables的几个字段都是公开的,意味着任何代码都可以直接使用,这个也是个可能导致问题的因素。
如果内存有泄露,调用System.gc没任何帮助。
这段代码问题挺多的,不过不是完整代码,所以也不能确定哪个地方会有内存泄露,你最好让代码运行一段时间,然后用jmap dump下jvm,然后用virtual vm来查看该dump文件,看看到底是queue引用的对象还是map里面的对象没有被回收导致的。