MST

星途 面试题库

面试题:Java线程异常处理器在多线程场景下的协同问题

在一个Java多线程应用中,存在多个工作者线程,这些线程共享同一个资源。如果其中一个线程因资源竞争引发异常,如何通过异常处理器保证其他线程不受影响,同时对异常进行合理处理?请阐述设计思路并给出部分核心代码。
15.6万 热度难度
编程语言Java

知识考点

AI 面试

面试题答案

一键面试

设计思路

  1. 使用线程局部变量:每个线程可以通过ThreadLocal持有自己对共享资源的“副本”,减少直接竞争。
  2. 独立的异常处理器:每个线程设置独立的异常处理器,当某个线程出现异常时,异常仅在该线程内处理,不会影响其他线程。
  3. 资源保护:对共享资源的访问进行同步控制,防止异常情况下资源处于不一致状态。

核心代码示例

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

public class ThreadExceptionHandling {
    // 共享资源
    private static final SharedResource sharedResource = new SharedResource();

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        for (int i = 0; i < 3; i++) {
            executorService.submit(() -> {
                Thread.currentThread().setUncaughtExceptionHandler((t, e) -> {
                    // 异常处理逻辑
                    System.err.println("Thread " + t.getName() + " has an exception: " + e.getMessage());
                });
                try {
                    // 模拟对共享资源的操作
                    sharedResource.accessResource();
                } catch (Exception e) {
                    // 这里也可以进行局部处理
                    throw new RuntimeException(e);
                }
            });
        }

        executorService.shutdown();
    }
}

class SharedResource {
    // 模拟共享资源的访问
    public void accessResource() throws Exception {
        // 假设这里可能会抛出资源竞争异常
        if (Math.random() < 0.5) {
            throw new Exception("Resource competition exception");
        }
        System.out.println(Thread.currentThread().getName() + " accessed resource successfully.");
    }
}

在上述代码中:

  1. Thread.currentThread().setUncaughtExceptionHandler为每个线程设置了独立的异常处理器,当线程出现未捕获异常时,该处理器会捕获并处理异常。
  2. SharedResource类模拟了共享资源,accessResource方法模拟对共享资源的访问,该方法可能会抛出资源竞争异常。
  3. 通过ExecutorService创建线程池并提交任务,每个任务在线程中独立运行,异常不会影响其他线程。