阿里巴巴规范中关于线程的创建

1. 创建方式介绍

new Thread 方式

优势：显而易见的线程创建方式

缺点：每次都要new对象，当有大量请求时，数不清new了多少个对象了，如果不及时关闭会导致内存溢出，因此还要考虑线程管理等问题。

Executors工厂创建线程池

统一缺点：不支持自定义拒绝策略。

• newCachedThreadPool：创建一个可缓存线程池

优点：很灵活，弹性的线程池线程管理，用多少线程给多大的线程池，不用后及时回收，用则新建

缺点：一旦线程无限增长，会导致内存溢出。

• newFixedThreadPool ：

优点：创建一个固定大小线程池，超出的线程会在队列中等待。

缺点：不支持自定义拒绝策略，大小固定，难以扩展

• newScheduledThreadPool ：

优点：创建一个固定大小线程池，可以定时或周期性的执行任务。

缺点：任务是单线程方式执行，一旦一个任务失败其他任务也受影响

• newSingleThreadExecutor ：

优点：创建一个单线程的线程池，保证线程的顺序执行

缺点：不适合并发。。不懂为什么这种操作要用线程池。。为什么不直接用队列

通过ThreadPoolExecutor创建线程池(阿里巴巴规范要求）

优点：集上述优点于一身

缺点：没发现缺点，因为上述线程池的底层就是通过它来创建的。。哈哈哈

举个例子！

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());

    }

你会发现Executors的底层就是ThreadPoolExecutor。。只不过加了很多限制，剩下的自己翻源码去！！

2. ThreadPoolExecutor介绍

首先我们先来看看ThreadPoolExecutor的构造函数，通过构造函数的参数来认识一下如何构造一个线程池

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue) 
// 用给定的初始参数和默认的线程工厂及被拒绝的执行处理程序创建新的 ThreadPoolExecutor。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long 
keepAliveTime, TimeUnit unit, BlockingQueue workQueue, 
RejectedExecutionHandler handler) 
// 用给定的初始参数和默认的线程工厂创建新的 ThreadPoolExecutor。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long 
keepAliveTime, TimeUnit unit, BlockingQueue workQueue, 
ThreadFactory threadFactory) 
// 用给定的初始参数和默认被拒绝的执行处理程序创建新的 ThreadPoolExecutor。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long 
keepAliveTime, TimeUnit unit, BlockingQueue workQueue, 
ThreadFactory threadFactory, RejectedExecutionHandler handler) 
// 用给定的初始参数创建新的 ThreadPoolExecutor。

其实前面三个构造函数在底层都是使用第四个构造方法，只是在调用的过程中添加了一些默认的条件而已，好，那现在我们根据第四个构造函数的参数来认识线程池

• 核心corePoolSize和最大池大小maximumPoolSize

根据这两个参数设置的边界，自动调整池大小

如果运行的线程少于 corePoolSize，则创建新线程来处理请求，即使其他辅助线程是空闲的。如果运行的线程多于 corePoolSize 而少于 maximumPoolSize，则仅当队列满时才创建新线程。如果设置的 corePoolSize 和 maximumPoolSize 相同，则创建了固定大小的线程池。如果将 maximumPoolSize 设置为基本的无界值（如 Integer.MAX_VALUE），则允许池适应任意数量的并发任务。在大多数情况下，核心和最大池大小仅基于构造来设置，不过也可以使用 setCorePoolSize(int) 和 setMaximumPoolSize(int) 进行动态更改。

• 保持活动时间keepAliveTime

如果池中当前有多于 corePoolSize 的线程，则这些多出的线程在空闲时间超过 keepAliveTime 时将会终止（参见 getKeepAliveTime(java.util.concurrent.TimeUnit)）。这提供了当池处于非活动状态时减少资源消耗的方法。如果池后来变得更为活动，则可以创建新的线程。也可以使用方法 setKeepAliveTime(long, java.util.concurrent.TimeUnit) 动态地更改此参数。使用 Long.MAX_VALUE TimeUnit.NANOSECONDS 的值在关闭前有效地从以前的终止状态禁用空闲线程。默认情况下，保持活动策略只在有多于 corePoolSizeThreads 的线程时应用。但是只要 keepAliveTime 值非 0，allowCoreThreadTimeOut(boolean) 方法也可将此超时策略应用于核心线程。

• 任务的排队BlockingQueue

所有 BlockingQueue 都可用于传输和保持提交的任务。可以使用此队列与池大小进行交互：

如果运行的线程少于 corePoolSize，则 Executor 始终首选添加新的线程，而不进行排队。
如果运行的线程等于或多于 corePoolSize，则 Executor 始终首选将请求加入队列，而不添加新的线程。
如果无法将请求加入队列，则创建新的线程，除非创建此线程超出 maximumPoolSize，在这种情况下，任务将被拒绝

• 被拒绝的任务RejectedExecutionHandler

当 Executor 已经关闭，并且 Executor 将有限边界用于最大线程和工作队列容量，且已经饱和时，在方法 execute(java.lang.Runnable) 中提交的新任务将被拒绝。在以上两种情况下，execute 方法都将调用其 RejectedExecutionHandler 的 RejectedExecutionHandler.rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor) 方法。

• threadFactorythreadFactory

线程工厂，提供创建新线程的功能。ThreadFactory是一个接口，只有一个方法