线程池超时时间等待线程池中的线程完成所有任务

不念不忘少年蓝@ 2023-06-29 02:47 76阅读 0赞

## newFixedThreadPool ##

创建一个固定大小的线程池。

1.  shutdown()：用于关闭启动线程，如果不调用该语句，jvm不会关闭。
2.  awaitTermination()：用于等待子线程结束，再继续执行下面的代码。该例中我设置一直等着子线程结束。
3.  isTerminated当调用shutdown()方法后，并且所有提交的任务完成后返回为true
4.  interrupt() 与 cancel()的区别

两者实际上都是中断线程，但是后者更安全、有条理和高效，其原因跟推荐使用[Executor][]而不直接使用Thread类是一致的。所以结合上面讲到的原则，我们应尽量采用cancel()方法，调用线程管理器ExecutorService接口的[**submit**][submit]([Runnable][] task) 方法会返回一个Future<?>对象，然后调用Future.cancel()的方法来取消任务，并返回一个boolean值。

![2020011010365239.png][]

1.测试线程类

package com.fullrich.pay.batch.task;
    
    class Task implements Runnable {
            public String name;
            private int time;
    
            public Task(String s, int t) {
                name = s;
                time = t;
            }
    
            public void run() {
                System.out.println( name  + " 开始执行");
                    try {
                        Thread.sleep(time*1000);
                        System.out.println( name  + " 执行完毕");
                    } catch (InterruptedException e) {
                        System.out.println(name
                                + "此线程超时将要被终端");
                         return ;// 注意这里如果不return的话，线程还会继续执行，所以任务超时后在这里处理结果然后返回  for循环中  
                    }
            }
        }

2.测试isTerminated（）的作用

public static void main(String[] args) {
            ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);
            for(int i=0;i<5;i++){
                try{
                    Task task=new Task("任务"+i,i);
                    fixedThreadPool.execute(task);
                }catch(Exception e){
                    logger.info("执行中出现其他异常");
                    e.printStackTrace();
                    continue;
                }
            }
            fixedThreadPool.shutdown();
            //2.等待线程全部执行完毕以后会输出主线程执行完毕
            while(true){
                //等待线程池所有的任务执行完
                if(fixedThreadPool.isTerminated()){
                    logger.info("主线程执行完毕");
                    break;
                }
            }
        }

2.测试awaitTermination（）的作用

public static void main(String[] args) {
            ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);
            List<Future<?>> futures = new ArrayList<Future<?>>();
            for(int i=0;i<5;i++){
                //这里可以使用多线程进行对多个商户的订单进行查询余额操作
                try{
                    Task task=new Task("任务"+i,i);
                    Future<?> future = fixedThreadPool.submit(task);
                    futures.add(future);
                    System.out.println("-----------");
                }catch(Exception e){
                    logger.info("执行中出现其他异常");
                    e.printStackTrace();
                    continue;
                }
            }
            fixedThreadPool.shutdown();
    
            //所有线程在3s内执行完毕后会输出主线程执行完毕否则中断超时任务
            try {
                //awaitTermination会一直等待所有的任务都结束，或者超时时间到立即返回，若所有任务都完成则返回true，否则返回false
                if (fixedThreadPool.awaitTermination(3, TimeUnit.SECONDS)) {
                    logger.info("主线程执行完毕");
                } else {
                    System.out.println("某个任务超时进行中断处理");
                    for (Future<?> f : futures) {
                        if (!f.isDone()) {
                            f.cancel(true);
                        }
                    }
                }
            } catch (InterruptedException e) {
                System.out.println("执行被中断");
            }
    
        }

[Executor]: http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/Executor.html
[submit]: http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/ExecutorService.html#submit%28java.lang.Runnable%29
[Runnable]: http://java.sun.com/j2se/1.5.0/docs/api/java/lang/Runnable.html
[2020011010365239.png]: https://img-blog.csdnimg.cn/2020011010365239.png