Java線程池,isShutDown、isTerminated的作用與區別


isShutDown當調用shutdown()或shutdownNow()方法后返回為true。 
isTerminated當調用shutdown()方法后,並且所有提交的任務完成后返回為true;
isTerminated當調用shutdownNow()方法后,成功停止后返回為true;
如果線程池任務正常完成,都為false

import java.util.concurrent.Callable;
 
public class ShortTask implements Callable {
    @Override
    public Object call() throws Exception {
        System.out.println("短任務");
        return null;
    }
}

 

import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
 
public class LongTask implements Callable {
    @Override
    public Object call() throws Exception {
        System.out.println("長任務");
        TimeUnit.SECONDS.sleep(5);
        return null;
    }
}

  

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
 
public class Main {
 
    public static void main(String[] args) {
        ScheduledExecutorService service = Executors.newScheduledThreadPool(4);
        service.submit(new ShortTask());
        service.submit(new ShortTask());
        service.submit(new LongTask());
        service.submit(new ShortTask());
        System.out.println("isShutdown:" + service.isShutdown());
        System.out.println("isTerminated:" + service.isTerminated());
        service.shutdown();
//        List<Runnable> list = service.shutdownNow();
//        System.out.println(list.size());
        System.out.println("isShutdown:" + service.isShutdown());
        System.out.println("isTerminated:" + service.isTerminated());
        try {
            while (!service.awaitTermination(1, TimeUnit.SECONDS)) {
                System.out.println("線程池沒有關閉");
                System.out.println("isTerminated:" + service.isTerminated());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
 
        System.out.println("線程池已經關閉");
        System.out.println("isTerminated:" + service.isTerminated());
    }
}
 

  

 
/*
執行service.shutdown();
短任務
短任務
長任務
短任務
isShutdown:false
isTerminated:false
isShutdown:true
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池已經關閉
isTerminated:true*/
 
/*
執行List<Runnable> list = service.shutdownNow();
System.out.println(list.size());
短任務
短任務
長任務
isShutdown:false
isTerminated:false
1
isShutdown:true
isTerminated:false
線程池已經關閉
isTerminated:true
*/
 
/*
如果不執行shutdown,也不執行shutdownNow:
短任務
短任務
長任務
短任務
isShutdown:false
isTerminated:false
isShutdown:false
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
線程池沒有關閉
isTerminated:false
......一直這樣輸出
*/

  


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM