【Java并发】线程池

线程池的执行策略

1. 判断核心线程池是否已满？不满，new一个线程执行任务；满了，执行步骤2
2. 线程队列是否已满？不满，放在工作队列里；满了，new一个线程执行任务。
3. 判断线程是否超过最大线程数？未超过，可以new线程执行任务；超过了，任务被拒绝，执行
   RejectedExecutionHandler.rejectedExecution()方法
4. 当一个线程完成任务，则从队列中取任务继续执行
5. 如果线程不在工作，超过设定的超时时间（
   keepAliveTime），如果线程大于corePoolSize，这个线程被停掉。

线程队列：

拒绝策略：

举例：

package test.java;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TestThreadPool {
    
    public static void main( String[] args ) {
        ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(10);
        ThreadPoolExecutor t = new ThreadPoolExecutor(2, 4, 1000, TimeUnit.MILLISECONDS, queue);
        for (int i = 0; i < 10; i++) {
            TestThreadPool a = new TestThreadPool();
            TaskWorker task = a.new TaskWorker("task--" + i);
            t.execute(task);
        }
        
    }
    
    class TaskWorker implements Runnable {
        private String name;
        
        public TaskWorker(String name) {
            this.name = name;
        }
        
        public void run() {
            System.out.println(System.currentTimeMillis()+ " taskName: " + name);
        }
        
    }
}