import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/***线程池创建*/
public class Demo1 {public static void main(String[] args) {ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(//核心线程数量50,//最大线程数量100,//等待时间10,//等待时间单位TimeUnit.SECONDS,//阻塞队列,最多排队人数new ArrayBlockingQueue<>(10),//默认线程工厂Executors.defaultThreadFactory(),//超出线程池的线程拒绝策略,拒绝并抛异常new ThreadPoolExecutor.AbortPolicy());}
}