我有一个 Java 多线程问题。我有以下工人阶级:
public class ThreadWorker implements Runnable {
//some code in here
public void run(){
// invokes some recursion method in the ThreadWorker itself,
// which will stop eventually
{
}
要使用线程,我使用的是ExecutorService
:
public static int THREAD_NUMBER = 4;
public static ExecutorServide es = Executors.newFixedThreadPool(THREAD_NUMBER);
添加类的实例ThreadWroker
发生在这里:
public void recursiveMethod(Arraylist<Integers> elements, MyClass data){
if (elements.size() == 0 && data.qualifies()){
ThreadWorker tw = new ThreadWorker(data);
es.execute(tw);
return;
}
for (int i=0; i< elements.size(); i++){
// some code to prevent my problem
MyClass data1 = new MyClass(data);
MyClass data2 = new MyClass(data);
ArrayList<Integer> newElements = (ArrayList<Integer>)elements.clone();
data1.update(elements.get(i));
data2.update(-1 * elements.get(i));
newElements.remove(i);
recursiveMethod(newElements, data1);
recursiveMethod(newElements, data2);
{
}
问题是递归树的深度很大,因为它的宽度,所以很多ThreadWorkers
都添加到了ExecutorService
,所以在大输入上一段时间后得到
Exception in thread "pool-1-thread-2" java.lang.OutOfMemoryError: Java heap space
这是造成的,我认为是因为要执行的ThreadWorkers
i数量庞大,所以内存不足。ExecutorSirvice
每个都ThreadWorker
需要大约 40 Mb 的 RAM 来满足它的所有需求。
有没有一种方法可以获取添加了多少线程(实现可运行接口的类的实例)ExecutorService
?所以我可以在上面显示的代码中添加它(int the " // some code to prevent my problem"),如
while ("number of threads in the ExecutorService" > 10){
Thread.sleep(10000);
}
所以我不会深入或广泛地使用递归并防止那些抛出异常的情况。
此致, 谢尔盖·阿加尼佐夫 jr。