java - Spring 任务执行器 :How to get notifed when all task complete execution and also if they dont in some time slot

Question

我是 Java 编程的新手，但遇到了一个问题。我正在使用 Spring TaskExecutor 接口(interface)进行线程池管理。我必须并行地从不同来源(Http、文件、数据库)提取内容，因此我为此使用了 TaskExecutor。现在我希望一旦所有线程都完成执行，它应该指示 TaskExecutor，如果它们没有在 4 秒内完成执行，则任务应该被终止。所以我被这个问题困住了。我尝试将可调用接口(interface)与 future 一起使用，但这会导致任务同步执行，但我需要异步。请帮帮我。

Answer 1

您还可以在创建任务后创建一个循环并检查超时:

 ApplicationContext context = new ClassPathXmlApplicationContext("Spring-Config.xml");
ThreadPoolTaskExecutor taskExecutor = (ThreadPoolTaskExecutor) context.getBean("taskExecutor");
taskExecutor.execute(new PrintTask("YOUR TASK ONE"));
taskExecutor.execute(new PrintTask("YOUR TASK TWO"));

double timeOutMs = 3000.0 ; // 3 seconds of maximum duration
double startTime = System.currentTimeMillis() ;

//check active thread, if zero then shut down the thread pool
for (;;) {
    int count = taskExecutor.getActiveCount();
    System.out.println("Active Threads : " + count);

                if (System.currentTimeMillis() - startTime > timeOutMs) {
                    // Do something : its to late, cancel the tasks !
                } 

    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    if (count == 0) {
        taskExecutor.shutdown();
        break;
    }
}

}