如何在ThreadPoolExecutor中实现submit方法吞噬异常，但执行-not

在ThreadPoolExecutor中，可以通过自定义FutureTask来实现submit方法吞噬异常，但执行不阻塞的效果。

首先，需要了解ThreadPoolExecutor的submit方法返回的是一个Future对象，用于表示异步任务的执行结果。默认情况下，如果异步任务抛出异常，调用Future对象的get方法会将异常重新抛出，导致阻塞。

为了实现submit方法吞噬异常，可以自定义一个继承自FutureTask的任务类，并重写其done方法。在done方法中，可以通过调用get方法获取任务执行过程中抛出的异常，并进行处理，避免异常被重新抛出。

以下是一个示例代码：

import java.util.concurrent.*;

public class ExceptionSwallowingTask<V> extends FutureTask<V> {
    public ExceptionSwallowingTask(Callable<V> callable) {
        super(callable);
    }

    @Override
    protected void done() {
        try {
            get();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } catch (ExecutionException e) {
            // 异常处理逻辑，可以根据具体需求进行处理
            System.err.println("任务执行过程中发生异常：" + e.getCause());
        }
    }
}

public class Main {
    public static void main(String[] args) {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                10, 10, 0, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>()
        );

        Callable<Integer> task = () -> {
            // 模拟任务执行过程中抛出异常
            throw new RuntimeException("任务执行异常");
        };

        // 使用自定义的任务类
        Future<Integer> future = executor.submit(new ExceptionSwallowingTask<>(task));

        try {
            // 获取任务执行结果，不会抛出异常
            Integer result = future.get();
            System.out.println("任务执行结果：" + result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        executor.shutdown();
    }
}

在上述代码中，自定义的ExceptionSwallowingTask类继承自FutureTask，并重写了done方法。在done方法中，通过调用get方法获取任务执行过程中的异常，并进行处理。在Main类中，使用ThreadPoolExecutor提交任务时，使用自定义的ExceptionSwallowingTask类来包装任务，从而实现了submit方法吞噬异常，但执行不阻塞的效果。

需要注意的是，通过这种方式吞噬异常可能会导致任务执行结果不可靠，因为异常被吞噬后无法及时发现。因此，在实际应用中，需要根据具体需求和场景来决定是否使用这种方式。