java方法执行超时关闭

Posted 2021-12-07 min-yu

1. Callable<String> task = new Callable<String>() {
2.             @Override
3.             public String call() throws Exception{
4.                 //执行耗时代码
5.                 Thread.sleep(10000);
6.                 return "success";
7.             }
8.         };
10.         ExecutorService executorService = Executors.newSingleThreadExecutor();
11.         Future<String> future = executorService.submit(task);
12.         try {
13.             //设置超时时间
14.             String rst = future.get(5,TimeUnit.SECONDS);
15.             System.out.println(rst);
16.         } catch (TimeoutException e) {
17.             System.out.println("执行超时");
18.         } catch(Exception e){
19.             System.out.println("获取数据异常," + e.getMessage());
20.         }finally {
21.             executorService.shutdown();
22.         }