Java口试题:线程池内“闹感情”的线程,怎么办?

打印 上一主题 下一主题

主题 843|帖子 843|积分 2529

在Java中,线程池中工作线程出现非常的时候,默认会把非常往外抛,同时这个工作线程会因为非常而销毁,我们需要自己去处理对应的非常,非常处理的方法有几种:

  • 在通报的任务中去处理非常,对于每个提交到线程池中的实行的任务,可以提前通过非常进行捕捉,如许即便出现了非常,也不会影响线程池中的工作线程
  • 使用Future来捕捉非常结果,在线程池中提供了一个submit(Callable)方法,这个方法会返回一个Future,可以通过调用Future.get()方法,来获取任务的实行结果,假如任务实行过程中出现了非常,也会抛出一个ExecutionException,其中就包含了任务实行过程中出现的非常
  • 我们还可以自定义一个ThreadFactory,设置一个UncaughtExceptionHandler,我们可以通过实现ThreadFactory的接口来自定义创建线程的方式,然后为每个新创建的线程设置一个UncaughtExceptionHandler,这个处理器会在线程由于未捕捉非常而即将终止的时候被调用
下面是三段代码示例:
捕捉线程实行非常
  1. ExecutorService executorService = Executors.newFixedThreadPool(5);
  2. executorService.execute(() -> {
  3.     try {
  4.         // 执行任务
  5.     } catch (Exception e) {
  6.         // 记录日志
  7.         logger.error("An exception occurred: ", e);
  8.     }
  9. });
复制代码
在实行任务的过程中,假如出现非常,就会被try-catch语句捕捉,并将非常信息记载到日记中。
 
使用Future来捕捉非常结果
  1. ExecutorService executorService = Executors.newFixedThreadPool(5);
  2. List<Future<?>> futures = new ArrayList<>();
  3. // 提交任务到线程池
  4. for (int i = 0; i < 10; i++) {
  5.     Future<?> future = executorService.submit(() -> {
  6.         // 执行任务
  7.     });
  8.     futures.add(future);
  9. }
  10. // 获取任务结果
  11. for (Future<?> future : futures) {
  12.     try {
  13.         future.get();
  14.     } catch (InterruptedException | ExecutionException e) {
  15.         // 处理异常
  16.         logger.error("An exception occurred: ", e);
  17.     }
  18. }
复制代码
在这个例子中,我们将多个任务提交到线程池,并将每个任务的Future对象保存在futures列表中。接着,我们遍历futures列表,并调用每个Future对象的get()方法来获取任务的实行结果。假如任务实行过程中出现了非常,则会抛出ExecutionException非常,我们在catch块中捕捉该非常并进行相应的处理。
 
实现UncaughtExceptionHandler接口
  1. public class CustomExceptionHandler implements Thread.UncaughtExceptionHandler {
  2.     @Override
  3.     public void uncaughtException(Thread t, Throwable e) {
  4.         // 记录日志或者进行其它处理
  5.         logger.error("Thread " + t.getName() + " encountered an exception: ", e);
  6.     }
  7. }
  8. ExecutorService executorService = Executors.newFixedThreadPool(5);
  9. // 设置UncaughtExceptionHandler
  10. ((ThreadPoolExecutor) executorService).setThreadFactory(r -> {
  11.     Thread thread = new Thread(r);
  12.     thread.setUncaughtExceptionHandler(new CustomExceptionHandler());
  13.     return thread;
  14. });
  15. executorService.execute(() -> {
  16.     // 执行任务
  17. });
复制代码
这种方式需要自定义一个实现了UncaughtExceptionHandler接口的非常处理器,当线程出现非常时,非常处理器会被调用,我们可以在其中记载日记或者进行别的处理。接着,我们需要将非常处理器设置到线程池的线程工厂中。当线程池内的线程出现非常时,非常处理器就会被调用,我们可以在其中处理非常。
  

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

徐锦洪

金牌会员
这个人很懒什么都没写!
快速回复 返回顶部 返回列表