Java Task Timeout: Force Termination & Exceptions

In Java, you can use the shutdownNow() method of the ExecutorService interface to forcibly terminate and throw tasks. This method attempts to immediately stop all tasks in execution and returns a list containing the tasks that were not executed.

Below is a simple example code demonstrating how to use ExecutorService and the shutdownNow() method to forcibly terminate and throw tasks:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.List;

public class Main {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newSingleThreadExecutor();

        // 提交一个任务
        executor.submit(() -> {
            try {
                Thread.sleep(5000); // 模拟一个耗时任务
            } catch (InterruptedException e) {
                System.out.println("任务被中断");
                return;
            }
            System.out.println("任务完成");
        });

        // 等待一段时间后强制结束任务
        try {
            List<Runnable> remainingTasks = executor.shutdownNow();
            if (!remainingTasks.isEmpty()) {
                System.out.println("强制结束任务");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

In this example, we start by creating an ExecutorService and submitting a task that takes 5 seconds. After waiting for a period of time, we use the shutdownNow() method to forcefully end the task. If there are any tasks that have not been executed, a message will be printed.