package pool;

import java.util.concurrent.*;

/**

* @author ： CodeWater

* @create ：2022-06-03-20:35

* @Function Description ：自定义线程池

* 超过最大办理线程数量会抛出异常

*/

public class ThreadPoolDemo2 {

public static void main(String[] args) {

ExecutorService threadPool = new ThreadPoolExecutor(

2,

5 ,

2L,

TimeUnit.SECONDS,

new ArrayBlockingQueue<>(3) ,

Executors.defaultThreadFactory(),

new ThreadPoolExecutor.AbortPolicy()

);

//10个顾客请求

try{

for( int i = 0 ; i < 10 ; i++ ){

//执行

threadPool.execute( () -> {

System.out.println( Thread.currentThread().getName() + "办理业务。" );

});

}

}catch( Exception e ){

e.printStackTrace();

}finally{

threadPool.shutdown();

}

}

}