java - java中的多个并行线程不会终止

Question

我尝试在java中运行一组并行线程。我通过高阶函数创建它们，如下所示:

public static void parallelizedMap(Consumer<String> f, List<String> list, int count) {
    List<List<String>> parts = new ArrayList<List<String>>();
    final int N = list.size();
    int L = N / (count - 1);
    for (int i = 0; i < N; i += L) {
        parts.add(new ArrayList<String>(list.subList(i, Math.min(N, i + L))));
    }
    for (List<String> e : parts) {
        Runnable r = new Runnable() {
            public void run() {
                e.forEach(f);
            }
        };
        new Thread(r).start();
    }
}

此方法每隔几分钟调用一次。几分钟后它会创建数百个线程。每个线程只运行 20 秒。但我的调试表明它们永远不会终止，因此我得到这个异常:

java.lang.OutOfMemoryError: GC overhead limit exceeded

提前致谢

Answer 1

我不认为问题出在线程上。但如果计数是列表大小的两倍或以上:

final int N = list.size(); // N = 10, count = 22
int L = N / (count - 1);  // L = 10 / (22-1) = 0.476 / L = 0.4d = (int) 0;
for (int i = 0; i < N; i += 0) {
     parts.add(new ArrayList<String>(list.subList(i, Math.min(N, i + 0))));
}

迭代是一个无限循环，但内存使用量每次迭代都会增加。

自然是内存不足。