为什么我的代码会创建很多线程（java.lang.OutOfMemoryError:无法创建新的本机线程）

Question

我试图通过拆分列表来检查元素是否在字符串中：

`公共类ParallelSearchComment扩展了RecursiveTask{private static final long serialVersionUID=1L；

int lo; 
int hi; 
String com;
String query;
int T;

ParallelSearchComment(String c, int l, int h, String q, int Treshold){
    com=c;
    lo=l;
    hi=h;
    query=q;
    T=Treshold;
}

private int findMiddle(String text){ // Only split at whitespace chars (or some words would be missed) 

    int middle = lo + ((hi - lo)/2);
    int i= middle;                                                            
    for (i = middle; i != hi && com.charAt(middle) != ' ' && i-middle <= query.length()+1; i++){

    }  
    middle = i;
    return middle;
}

@Override
protected Boolean compute() {
    int middle = findMiddle(com);
    if (hi - lo < T || hi-middle <= query.length()) {//hi-middle <= query.length()
        return com.substring(lo, hi).contains(query);
    } else {

        ParallelSearchComment left = new ParallelSearchComment(com, lo, middle, query, T);
        ParallelSearchComment right = new ParallelSearchComment(com, middle, hi, query, T);

        left.fork();
        boolean resRight = right.compute();
        boolean resLeft = left.join();

        return resRight || resLeft;
    }

}

static boolean ParallelSearchComment(String c, String query, int T,int p) {
    final ForkJoinPool fjPool = new ForkJoinPool(p);
    ParallelSearchComment t = new ParallelSearchComment(c, 0, c.length(), query, T);
    return fjPool.invoke(t);
}

`

Answer 1

由于您的代码段没有显示如何调用静态布尔值ParallelSearchComment，我将假设它被用于初始化搜索。另外，我将假设您只从您的main中触发了一次搜索。

这样，您传递的并行性值（或p）很可能高于当前JVM堆所能处理的值。看看当你把它减少到5或10时会发生什么。

Answer 2

问题是，每次调用ParallelSearchComment时，您都在创建一个新的ForkJoinpool实例。相反，您应该创建一个ForkJoinPool并在整个应用程序中使用。