首页 | 新闻 | 新品 | 文库 | 方案 | 视频 | 下载 | 商城 | 开发板 | 数据中心 | 座谈新版 | 培训 | 工具 | 博客 | 论坛 | 百科 | GEC | 活动 | 主题月 | 电子展
返回列表 回复 发帖

多线程---java判断多线程结束(1)

多线程---java判断多线程结束(1)

需求应用场景

我们多线程抓取数据或者多线程执行任务时,有时候需要多线程执行完后      才能执行其他的任务。

这种情况下  我们就需要判断多线程什么时候执行完。有以下几种方法(推荐方法二)





方法一 isTerminated
使用isTerminated来判断所有任务都已完成,会返回true。但是前提是启用shutdown顺序关闭。

shutdown
void shutdown()
启动一次顺序关闭,执行以前提交的任务,但不接受新任务。如果已经关闭,则调用没有其他作用。
抛出:
SecurityException - 如果安全管理器存在并且关闭,此 ExecutorService 可能操作某些不允许调用者修改的线程(因为它没有保持RuntimePermission("modifyThread")),或者安全管理器的 checkAccess 方法拒绝访问。


isTerminated
boolean isTerminated()
如果关闭后所有任务都已完成,则返回 true。注意,除非首先调用 shutdown 或 shutdownNow,否则 isTerminated 永不为 true。
返回:
如果关闭后所有任务都已完成,则返回 true




使用例子

先调用shundown再调用isTerminated判断

    /**
     * 采用线程池开启多个子线程,主线程等待所有的子线程执行完毕  
     */  
    public static void moreThread() {  
        try {  
            int threadNum = 0;  
            for (int i = 0; i < 10; i++) {  
                threadNum++;  
                  
                final int currentThreadNum = threadNum;  
                exe.execute(new Runnable() {  
                     
                    @Override  
                    public void run() {  
                        try {  
                            System.out.println("子线程[" + currentThreadNum + "]开启");  
                            Thread.sleep(1000*10);  
                        } catch (InterruptedException e) {  
                            e.printStackTrace();  
                        }finally{  
                            System.out.println("子线程[" + currentThreadNum + "]结束");  
                        }  
                    }  
                });   
            }  
              
            System.out.println("已经开启所有的子线程");  
            exe.shutdown();  
            System.out.println("shutdown():启动一次顺序关闭,执行以前提交的任务,但不接受新任务。");  
            while(true){  
                if(exe.isTerminated()){  
                    System.out.println("所有的子线程都结束了!");  
                    break;  
                }  
                Thread.sleep(1000);   
            }  
              
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }finally{  
            System.out.println("主线程结束");  
        }  
    }  




输出结果
子线程[1]开启  
子线程[6]开启  
子线程[2]开启  
子线程[5]开启  
子线程[9]开启  
已经开启所有的子线程  
子线程[3]开启  
子线程[7]开启  
子线程[10]开启  
shutdown():启动一次顺序关闭,执行以前提交的任务,但不接受新任务。  
子线程[4]开启  
子线程[8]开启  
子线程[6]结束  
子线程[3]结束  
子线程[7]结束  
子线程[2]结束  
子线程[1]结束  
子线程[5]结束  
子线程[9]结束  
子线程[4]结束  
子线程[10]结束  
子线程[8]结束  
所有的子线程都结束了!  
主线程结束
返回列表