关于子线程出现异常主线程获取的问题

￡神魔★判官ぃ 2024-02-19 15:51 45阅读 0赞

通过线程的不常用的一个接口Callable<T>来接收这个线程返回的状态

废话不多说直接上代码。

因为子线程中@Autowired注解不可以注入bean 我通过构造注入的方式来注入deparmentRep

FutureTask<String> futureTask = new FutureTask<>(new MyCallable(deparmentRep));// 创建一个 FutureTask，一旦运行就执行给定的 Callable线程。
    
    ExecutorService service = Executors.newCachedThreadPool();//  创建一个可根据需要创建新线程的线程池，但是在以前构造的线程可用时将重用它们。
    service.execute(futureTask);//在未来某个时间执行给定的命令。
    
    String msg = futureTask.get();//获得线程返回的状态

#### 线程实现类 ####

public class MyCallable implements Callable<String> {
    
    
        private static final Logger log = LoggerFactory.getLogger(MyThread.class);
     
    
        private DeparmentRep deparmentRep;
    
        public MyCallable(DeparmentRep deparmentRep) {
            this.deparmentRep = deparmentRep;
        }
    
        Deparment deparment = new Deparment();
    
        @Autowired
        public String call() {
    
            try {
                log.info("进入了run方法");
                Thread.sleep(5000);
                deparment.setName("邢春伟");
                System.out.println(1 / 0);
                deparmentRep.save(deparment);
                log.info("保存成功");
                return "保存成功";
            } catch (Exception e) {
                e.getStackTrace();
                log.info("子线程出现异常:" + e.getMessage());
                return "线程出现异常";
            } 
        }
    }

#### API上是这样解释的Callable<T> ####

返回结果并且可能抛出异常的任务。实现者定义了一个不带任何参数的叫做 call 的方法。

Callable 接口类似于 `Runnable`，两者都是为那些其实例可能被另一个线程执行的类设计的。但是 Runnable 不会返回结果，并且无法抛出经过检查的异常。

`Executors` 类包含一些从其他普通形式转换成 Callable 类的实用方法。

**从以下版本开始：**

1.5

**另请参见：**

`Executor`