ExecutorService pool = Executors.newSingleThreadExecutor();//线程池中只有一个线程 单个线程
/*
第一种方法：
运行结果发现，十个任务都是被同一个线程执行的
pool-1-thread-1--->ok pool-1-thread-1--->ok pool-1-thread-1--->ok pool-1-thread-1--->ok pool-1-thread-1--->ok
pool-1-thread-1--->ok pool-1-thread-1--->ok pool-1-thread-1--->ok pool-1-thread-1--->ok pool-1-thread-1--->ok
*/
ExecutorService pool = Executors.newFixedThreadPool(5);//创建了一个固定线程个数的线程池
/*
第二种方法：
根据运行结果可以看出来，最高同时有五个线程在执行，最多只能有nThreads个线程同时执行
pool-1-thread-1--->ok pool-1-thread-3--->ok pool-1-thread-4--->ok pool-1-thread-2--->ok
pool-1-thread-5--->ok pool-1-thread-4--->ok pool-1-thread-3--->ok pool-1-thread-1--->ok
pool-1-thread-5--->ok pool-1-thread-2--->ok
*/
ExecutorService pool = Executors.newCachedThreadPool();//遇强则强遇弱则弱
//开启了多少个线程，就有可能出现最高多少个线程同时执行
try {
for (int i = 0; i < 100; i++) {
//使用线程池之后就不用new Thread().start了 用线程池来开启线程
pool.execute(()->{
System.out.println(Thread.currentThread().getName() + "--->ok");
});
}
} catch (Exception e) {
e.printStackTrace();
} finally {
//线程池使用之后需要关闭
pool.shutdown();
}
七大参数和四种拒绝策略
/*
线程池的七大参数：
1、int corePoolSize, 线程池的核心线程大小
2、int maximumPoolSize, 线程池最大线程数量
3、long keepAliveTime, 空闲线程存活时间
4、TimeUnit unit, 空间线程存活时间单位
5、BlockingQueue<Runnable> workQueue, 工作队列
①ArrayBlockingQueue
基于数组的有界阻塞队列，按FIFO排序。新任务进来后，会放到该队列的队尾，有界的数组可以防止资源耗尽问题。当线程池中线程数量达到corePoolSize后，再有新任务进来，则会将任务放入该队列的队尾，等待被调度。如果队列已经是满的，则创建一个新线程，如果线程数量已经达到maxPoolSize，则会执行拒绝策略。
②LinkedBlockingQuene
基于链表的无界阻塞队列（其实最大容量为Interger.MAX），按照FIFO排序。由于该队列的近似无界性，当线程池中线程数量达到corePoolSize后，再有新任务进来，会一直存入该队列，而不会去创建新线程直到maxPoolSize，因此使用该工作队列时，参数maxPoolSize其实是不起作用的。
③SynchronousQuene
一个不缓存任务的阻塞队列，生产者放入一个任务必须等到消费者取出这个任务。也就是说新任务进来时，不会缓存，而是直接被调度执行该任务，如果没有可用线程，则创建新线程，如果线程数量达到maxPoolSize，则执行拒绝策略。
④PriorityBlockingQueue
具有优先级的无界阻塞队列，优先级通过参数Comparator实现。
6、ThreadFactory threadFactory, 线程工厂 创建一个新线程时使用的工厂，可以用来设定线程名、是否为daemon线程等等
7、RejectedExecutionHandler handler 拒绝策略
当工作队列中的任务已到达最大限制，并且线程池中的线程数量也达到最大限制，这时如果有新任务提交进来，该如何处理呢。这里的拒绝策略，就是解决这个问题的，jdk中提供了4中拒绝策略：
①CallerRunsPolicy
该策略下，在调用者线程中直接执行被拒绝任务的run方法，除非线程池已经shutdown，则直接抛弃任务。
②AbortPolicy
该策略下，直接丢弃任务，并抛出RejectedExecutionException异常。
③DiscardPolicy
该策略下，直接丢弃任务，什么都不做。
④DiscardOldestPolicy
该策略下，抛弃进入队列最早的那个任务，然后尝试把这次拒绝的任务放入队列
*/
public class PoolTestDemo01 {
/*
模拟银行业务，
现有两个柜台在办理业务（线程池中的核心线程个数），
最多只有五个柜台办理业务（线程池最大线程数量），
如果一个非核心线程开启之后超过keepAliveTime没有办理业务，就把他当作空闲线程处理掉（空闲线程存活时间），
候客区最多存放3人（阻塞队列）
new ThreadPoolExecutor.AbortPolicy()//银行满了 还有人进来就不处理这个人 抛出异常 RejectedExecutionException
new ThreadPoolExecutor.CallerRunsPolicy()//哪来的去哪里 超出部分 main代替执行了
new ThreadPoolExecutor.DiscardPolicy()//队列满了 丢掉超出的任务 不会抛出异常
new ThreadPoolExecutor.DiscardOldestPolicy()//替换旧的 尝试去和最早的竞争 看最早进来的是否快结束了 如果没有结束 依旧会把超出的抛出不执行 也不会抛出异常
*/
public static void main(String[] args) {
//自定义线程池 工作 ThreadPoolExecutor 阿里巴巴开发规范不推荐直接使用Executor创建线程池 不安全
ThreadPoolExecutor pool = new ThreadPoolExecutor(
2,
Runtime.getRuntime().availableProcessors();//获取当前电脑cpu最大核数==最大线程数
3,
TimeUnit.SECONDS,
new LinkedBlockingDeque<>(3),
Executors.defaultThreadFactory(),
//new ThreadPoolExecutor.AbortPolicy()//银行满了 还有人进来就不处理这个人 抛出异常 RejectedExecutionException
//new ThreadPoolExecutor.CallerRunsPolicy()//哪来的去哪里 超出部分 main代替执行了
new ThreadPoolExecutor.DiscardOldestPolicy()//替换旧的 尝试去和最早的竞争 看最早进来的是否快结束了 如果没有结束 依旧会把超出的抛出不执行
//new ThreadPoolExecutor.DiscardPolicy()//队列满了 丢掉超出的任务 不会抛出异常
);
try {
//最大承载 Deque + MAX (此程序中为3+5)
//超出最大承载后
for (int i = 1; i <=10; i++) {
pool.execute(()->{
System.out.println(Thread.currentThread().getName() + " ok");
});
}
} catch (Exception e) {
e.printStackTrace();
} finally {
pool.shutdown();
}
}
}
corePoolSize最大线程该如何定义
1.CPU密集型 ： 几核就定义几 可以保证cpu效率最高 Runtime.getRuntime().availableProcessors();
2.IO密集型 : 判断程序中十分耗IO占用资源的线程有多少个，最好的办法就是*2 让运行Io的同时还能运行其他线程.