Java常见线程池示例

作者: 老羊_肖恩 | 来源:发表于2018-01-18 14:18 被阅读111次

Java常见线程池示例
JAVA线程池常见用法及其原理
java 实现自定义线程池
JAVA线程池常见用法
Java线程池解析
线程池学习
Java多线程4 初识线程池
ThreadPoolExecutor
Java自学-多线程常见线程方法
Java线程池 - ThreadPoolExecutor示例

Java通过Executors提供了四种常见的线程池框架，分别为：
newFixedThreadPool：创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。
newSingleThreadExecutor：创建一个使用单个 worker 线程的 Executor，以无界队列方式来运行该线程。
newCachedThreadPool：创建一个可根据需要创建新线程的线程池，但是在以前构造的线程可用时将重用它们。
newScheduledThreadPool：创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。
接下来简单介绍一下这四种常用线程池的用法。

newFixedThreadPool

创建方法：

public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newFixedThreadPool(int nThreads,ThreadFactory threadFactory)

newFixedThreadPool创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。在任意点，在大多数 nThreads 线程会处于处理任务的活动状态。如果在所有线程处于活动状态时提交附加任务，则在有可用线程之前，附加任务将在队列中等待。如果在关闭前的执行期间由于失败而导致任何线程终止，那么一个新线程将代替它执行后续的任务（如果需要）。在某个线程被显式地关闭之前，池中的线程将一直存在。
示例代码：

/**
     * 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
     * 定长线程池的大小最好根据系统资源进行设置。
     */
    public static void newFixedThreadPoolDemos(){
        ExecutorService pool = Executors.newFixedThreadPool(3);
        
        for(int i = 0; i < 10; i++){
            final int index = i;
            pool.execute(()->{
                System.out.println("execute" + index);
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    System.out.println("Exception during sleep->" + e.getMessage());
                }
            });
        }
        System.out.println("isShutdown: " + pool.isShutdown() + "   isTerminated: " + pool.isTerminated());
        pool.shutdown();
//      pool.shutdownNow();
        System.out.println("isShutdown: " + pool.isShutdown() + "   isTerminated: " + pool.isTerminated());

        
        try {
            Thread.sleep(10000);
            System.out.println("isShutdown: " + pool.isShutdown() + "   isTerminated: " + pool.isTerminated());
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

newCachedThreadPool

创建方法：

public static ExecutorService newCachedThreadPool();
public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory);

创建一个可根据需要创建新线程的线程池，但是在以前构造的线程可用时将重用它们。对于执行很多短期异步任务的程序而言，这些线程池通常可提高程序性能。调用 execute 将重用以前构造的线程（如果线程可用）。如果现有线程没有可用的，则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。因此，长时间保持空闲的线程池不会使用任何资源。注意，可以使用 ThreadPoolExecutor 构造方法创建具有类似属性但细节不同（例如超时参数）的线程池。
示例代码：

/**
     * newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，
     * 可灵活回收空闲线程，若无可回收，则新建线程。线程池为无限大，当执行第二个
     * 任务时第一个任务已经完成，会复用执行第一个任务的线程，而不用每次新建线程。
     * 示例代码如下：
     */
    public static void newCachedThreadPoolDemos(){

        ExecutorService pool = Executors.newCachedThreadPool();
        for(int i = 0; i < 10; i++){
            final int index = i;
//          try{
//              Thread.sleep(index * 100);
//          }catch (InterruptedException e) {
//              e.printStackTrace();
//          }
            pool.submit(()->{
                System.out.println("submit->" + index);
                return null;
            });
//          pool.execute(()->{
//              System.out.println("execute->" + index);
//          });
        }
        System.out.println("------------------------------");
        pool.shutdown();
        pool.shutdownNow();
        System.out.println("isShutdown: " + pool.isShutdown());
        
        try {
            pool.execute(()->{
                System.out.println("after shutdown~~");
            });
        } catch (Exception e) {
            System.out.println("Exception after shutdown~~~~" + e.getMessage());
        }
        
    }

newScheduledThreadPool()

创建方法：

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize);
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize,ThreadFactory threadFactory);

创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。corePoolSize - 池中所保存的线程数，即使线程是空闲的也包括在内。
示例代码：

/**
     * 创建一个定长线程池，支持定时及周期性任务执行。
     */
    public static void newScheduledThreadPoolDemos(){
        System.out.println("start ... " + new Date());
        ScheduledExecutorService pool = Executors.newScheduledThreadPool(3);
        //表示延迟3秒执行
//      pool.schedule(()->{
//          System.out.println("delay 3 seconds...");
//      }, 3, TimeUnit.SECONDS);
        
        //延迟10秒后每3秒执行一次
        pool.scheduleWithFixedDelay(()->{
            System.out.println("delay 2 seconds..." + new Date());
        }, 10, 3, TimeUnit.SECONDS);
    }
}

newSingleThreadExecutor()

创建方法：

public static ExecutorService newSingleThreadExecutor();
public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory);

创建一个使用单个 worker 线程的 Executor，以无界队列方式来运行该线程。（注意，如果因为在关闭前的执行期间出现失败而终止了此单个线程，那么如果需要，一个新线程将代替它执行后续的任务）。可保证顺序地执行各个任务，并且在任意给定的时间不会有多个线程是活动的。与其他等效的 newFixedThreadPool(1) 不同，可保证无需重新配置此方法所返回的执行程序即可使用其他的线程。
示例代码：

/**
     * 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，
     * 保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
     * (可通过实现ThreadFactory来实现，newSingleThreadExecutor(ThreadFactory threadFactory))。
     */
    public static void newSingleThreadExecutorDemos(){
        ExecutorService pool = Executors.newSingleThreadExecutor();
        for(int i = 0; i < 10; i++){
            final int index = i;
            pool.execute(()->{
                System.out.println("execute -> " + index);
                try {
                    Thread.sleep(300);
                } catch (InterruptedException e) {
                    System.out.println("Exception during sleep: " + e.getMessage());
                }
            });
        }
        pool.shutdown();
    }