java - 线程的 run 方法完成后创建另一个线程

Question

我有一个扩展 Thread 类的类，如下所示。

public class RemoteDataSynchTaskProcessor extends Thread {
private GDRType taskGDR;

public RemoteDataSynchTaskProcessor(GDRType taskGDR) {
    this.taskGDR = taskGDR;
}

private void execute() {

    try {
        try {

            RemoteClient.runDataSynchTask(taskGDR);

        } catch (RemoteException re) {
            //.....
        } catch (NotBoundException e) {
            //......
        }
        processResult(false, "Success");
    } catch (DTSException de) {
    //....
    }

}

public void run() {
    Observer.incrementNumOfDataSyncyProcessor();

    try {
        execute();
    } finally {
        Observer.decrementNumOfDataSynchProcessor();
    }
}

该线程执行结束后，会出现另一个线程，名为:Thread [pool-34-thread-1] (Running)

我不知道为什么这个线程会出现并且永远不会终止，几天后我最终会得到数千个线程，并且池数量每次都会增加(例如线程 [pool-2500-thread-1])

如果调试并挂起这些生成的线程的执行，堆栈如下:

Thread [pool-1-thread-1] (Suspended)    
Unsafe.park(boolean, long) line: not available [native method]  
LockSupport.park(Object) line: 156  
AbstractQueuedSynchronizer$ConditionObject.await() line: 1987   
LinkedBlockingQueue<E>.take() line: 399 
ThreadPoolExecutor.getTask() line: 947  
ThreadPoolExecutor$Worker.run() line: 907   
Thread.run() line: 662  

这些线程是什么，我怎样才能摆脱它们？

编辑:似乎与我正在使用的闭源线程池库有关(根据询问执行器服务的评论来判断)。

我使用一个提供线程池功能的库。这就是我在应用程序启动开始时创建池的方式。

    ThreadPool fetcherPool = new ThreadPool("TASK_FETCHER", ConfigParams.minimumTaskFetcherCount, ConfigParams.maximumTaskFetcherCount, new TaskFetcher());

ThreadPool.java似乎是扩展了Java的ThreadGroup类，ThreadFetcher如下，它实际上触发了线程。

public class TaskFetcher extends PooledMessageWorker //Pooled Message Worker extends ReacreatableThread

public void run() {
    Observer.incrementNumOfTaskFetcher();
    try {
        while (true) {
            try {
                if (Observer.isShutdowned()) {
                    break;
                }
                ControllerUtil.getInstance().waitIfPaused();

                ESDRType task = (ESDRType) TaskHandler.getTask();
                if (task != null) {
                    trigger(task);
                }
            } catch (Exception e) {
                LogUtil.error(logger, e.getMessage(), e);
            }
        }
    } finally {
        Observer.decrementNumOfTaskFetcher();
    }
}


private void trigger(ESDRType task) {
    try {
        GDRType[] messages = createMessages(esdr);
    for (GDRType message : messages) {
        RemoteDataSynchTaskProcessor remoteCDCMTaskProcessor = new      RemoteDataSynchTaskProcessor(message);
        remoteCDCMTaskProcessor.start(); //This thread causes a new thread appear after execution finishes
        LogUtil.debug(logger, "[distributeMessage()] [Message: ", message, "]... [OK]");    
    }
    } catch (DTSException exception) {
    // Logging stuff
    }
}

}

Answer 1

您是否有理由必须使用闭源第 3 方 ThreadPool 库？如果没有，则将 RemoteDataSynchTaskProcessor 设为 Runnable (顺便说一句，我总是更喜欢扩展/实现 Runnable 而不是扩展 Thread)尝试将其与 ExecutorService 一起使用。

实际上，即使您必须使用第 3 方库，我也会尝试使用此方法进行调试。您可以缩小问题的范围。