线程池的使用

线程池的主要参数有以下6个。 1. corePoolSize（线程池基本大小）：当向线程池提交一个任务时，若线程池已创建的线程数小于 corePoolSize，就会通过创建一个新线程来执行该任务，直到已创建的线程数大于或等于 corePoolSize时，（除了利用提交新任务来创建和启动线程（按需构造），也可以通过 prestartCoreThread() 或 prestartAllCoreThreads() 方法来提前启动线程池中的基本线程。） 2. maximumPoolSize（线程池最大大小）：线程池所允许的最大线程个数。当队列满了，且已创建 的线程数小于maximumPoolSize，则线程池会创建新的线程来执行任务。另外，对于无界队列， 可忽略该参数。 3. keepAliveTime（线程存活保持时间）当线程池中线程数大于核心线程数时，线程的空闲时间如果 超过线程存活时间，那么这个线程就会被销毁，直到线程池中的线程数小于等于核心线程数。 4. workQueue（任务队列）：用于传输和保存等待执行任务的阻塞队列。 5. threadFactory（线程工厂）：用于创建新线程。threadFactory创建的线程也是采用new Thread()方式，threadFactory创建的线程名都具有统一的风格：pool-m-thread-n（m为线程池 的编号，n为线程池内的线程编号）。 6. handler（线程饱和策略）：当线程池和队列都满了，再加入线程会执行此策略。

package com.jg.unit8;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class Test1 {
    public static void main(String[] args) {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5, 10, 1L, TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(100), new ThreadPoolExecutor.CallerRunsPolicy());
        List list = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            Runnable runnable = new MyRunnable(i + "");
            executor.execute(runnable);
        }
    }
}

class MyRunnable implements Runnable {

    private String command;

    public MyRunnable(String command) {
        this.command = command;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "启动，当前时间：" + new Date());
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "结束，当前时间：" + new Date());
    }

    @Override
    public String toString() {
        return command;
    }
}