异常：java.lang.OutofMemoryError,无法创建新的本机线程

Question

它的发生是因为我创建了许多线程，而没有关闭它们？还是经常创造新的？

有人能告诉我在代码中是否做错了什么吗？

public class API{
    private   MongoStoreExecutor executor = new MongoStoreExecutor(10,50);
    private class MongoStoreExecutor extends ThreadPoolExecutor {
        public MongoStoreExecutor(int queueSize, int maxThreadPoolSize) {
            super(10, maxThreadPoolSize, 30, TimeUnit.SECONDS, 
                new ArrayBlockingQueue<Runnable>(queueSize),
                new ThreadPoolExecutor.CallerRunsPolicy());
        }
    }

    public TimerTask alertingPoolsData() throws Exception, UnknownHostException {
        TimeerTask task  = new TimerTask(){
            public void run(){
                Pools = alertingPools.values().toArray();
                List<Future<?>> tasks = new ArrayList<Future<?>>(Pools.length);
                for (Object pool : Pools) {
                    tasks.add(executor.submit(new DataAccumulation(timeStartSecData,
                        timeEndSec,pool, jsonArrayResult,dataResult)));
                }
                for( Future<?> f: tasks) {
                    f.get(2 * 1000L, TimeUnit.MILLISECONDS);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        long interval = 5 * 1000L;
        tm.scheduleAtFixedRate(task,(interval - 
            (System.currentTimeMillis() % interval)), interval);
        return task;
    }
}

Answer 1

我的预感与我们看不到的代码有关：我怀疑您在某个地方一遍又一遍地调用alertingpoolsdata。因此，我怀疑您正在一遍又一遍地调度TimerTask。这些组件中的每个组件TimerTasks然后重复创建未知数量的Future (池的每个元素对应一个元素），每个组件都将存储到您的MongoStoreExecutor中。

如果以上所有情况都是这样，那么线程计数曲线上的一阶导数为正。因此，随着时间的推移，您将看到线程数的二次增长。您将很快开始达到本机线程的上限。

正如注释中所建议的，您可以轻松地修改当前的实现。我建议使用ScheduledExecutorService和ForkJoinPool的组合。