java中线程池最实用的创建与关闭指南

private static ExecutorService executor = new ThreadPoolExecutor(10, 10,
        60L, TimeUnit.SECONDS,
        new ArrayBlockingQueue(10));

public class ExecutorsDemo {
 
    private static ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
        .setNameFORMat("demo-pool-%d").build();
 
    private static ExecutorService pool = new ThreadPoolExecutor(5, 200,
        0L, TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
 
    public static void main(String[] args) {
 
        for (int i = 0; i < Integer.MAX_VALUE; i++) {
            pool.execute(new SubThread());
        }
    }
}

package com.zxd.concurrent;

import com.Google.common.collect.Lists;

import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPool {


    public static void main(String[] args) {
        // TODO 如何正确优雅简单的关闭线程池 ，无须其他多余操 ；创建线程池我选择用这种方法比较可靠
        ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
        //接收处理数据的结果集合
        List<Integer> resList = Lists.newArrayList();
        //开启的任务 我们设置的核心处理线程数5个所以 会有多出来的线程在队列中等待
        for (int i = 0; i < 30; i++) {
            executor.execute(new Task(i, resList));
        }
        //1、关闭线程池 一定要在循环结束关闭
        //2、这个关闭方法不会立即关闭所有在执行的任务线程，
        executor.shutdown();
        //4.这里是检查线程池是否所有任务都执行完毕关闭
        int j = 0;
        while (true) {
            //5.这里是等线程池彻底关闭以后做的判断 保证所有线程池已经全部关闭退出while循环
            if (executor.isTerminated()) {
                System.out.println("所有线程已经运行完毕:" + j);
                break;
            }
            // 为避免一直循环 加个睡眠
            try {
                //如果执行shutdown方法没有关闭的线程池线程池会尝试关闭
                System.out.println("尝试关闭线程次数:" + j);
                j++;
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        //FIXME 3、下面的方法会立即关闭线程池，没有执行完的也不会在执行了，如果有等待队列的任务也不会继续执行
        System.out.println("【完成的总线程数】：" + resList.size());

    }

    static class Task implements Runnable {
        int name;

        List<Integer> list;

        public Task(int name, List<Integer> list) {
            this.name = name;
            this.list = list;
        }

        @Override
        public void run() {
            for (int i = 1; i <= 10; i++) {
                int j = i * 10;
                // 做业务处理
                //System.out.println("task " + name + " is running");
            }
            list.add(name + 1);
            System.out.println("task " + name + " is over");
        }
    }

}

package com.zxd.concurrent;

import com.google.common.collect.Lists;

import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPool {


    public static void main(String[] args) {
        // TODO 如何正确优雅简单的关闭线程池 ，无须其他多余操 ；创建线程池我选择用这种方法比较可靠
        ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
        //接收处理数据的结果集合
        List<Integer> resList = Lists.newArrayList();
        //开启的任务 我们设置的核心处理线程数5个所以 会有多出来的线程在队列中等待
        for (int i = 0; i < 200; i++) {
            executor.execute(new Task(i, resList));
        }
        //1、关闭线程池 一定要在循环结束关闭
        //2、这个关闭方法不会立即关闭所有在执行的任务线程，
//        executor.shutdown();
        //FIXME 3、下面的方法会立即关闭线程池，没有执行完的也不会在执行了，如果有等待队列的任务也不会继续执行
        List<Runnable> list = executor.shutdownNow();
        System.out.println("c剩余的没有执行的任务【线程数】= " + list.size());
        System.out.println("【完成的总线程数】：" + resList.size());
        //4.这里是检查线程池是否所有任务都执行完毕关闭
        int j = 0;
        while (true) {
            //5.这里是等线程池彻底关闭以后做的判断 保证所有线程池已经全部关闭退出while循环
            if (executor.isTerminated()) {
                System.out.println("所有线程已经运行完毕:" + j);
                break;
            }
            // 为避免一直循环 加个睡眠
            try {
                //如果执行shutdown方法没有关闭的线程池线程池会尝试关闭
                System.out.println("尝试关闭线程次数:" + j);
                j++;
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

    }

    static class Task implements Runnable {
        int name;

        List<Integer> list;

        public Task(int name, List<Integer> list) {
            this.name = name;
            this.list = list;
        }

        @Override
        public void run() {
            for (int i = 1; i <= 10; i++) {
                int j = i * 10;
                // 做业务处理
                //System.out.println("task " + name + " is running");
            }
            list.add(name + 1);
            System.out.println("task " + name + " is over");
        }
    }

}