package concurrency.pool;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class SaturationPolicy {
	/**
   * 線程池工作隊列已滿時，在不同飽和策略下表現(xiàn)
   * @param handler 線程池工作隊列飽和策略
   */
	public static void policy(RejectedExecutionHandler handler){
		//基本線程2個，最大線程數(shù)為3，工作隊列容量為5
		ThreadPoolExecutor exec = new ThreadPoolExecutor(2,3,0l, TimeUnit.MILLISECONDS,new LinkedBlockingDeque<>(5));
		if (handler != null){
			exec.setRejectedExecutionHandler(handler);
			//設(shè)置飽和策略
		}
		for (int i = 0; i < 10; i++) {
			exec.submit(new Task());
			//提交任務(wù)
		}
		exec.shutdown();
	}
	public static void main(String[] args) {
		//    policy(new ThreadPoolExecutor.AbortPolicy());
		//    policy((new ThreadPoolExecutor.CallerRunsPolicy()));
		//    policy(new ThreadPoolExecutor.DiscardPolicy());
		//    policy(new ThreadPoolExecutor.DiscardOldestPolicy());
	}
	//自定義任務(wù)
	static class Task implements Runnable {
		private static int count = 0;
		private int id = 0;
		//任務(wù)標(biāo)識
		public Task() {
			id = ++count;
		}
		@Override
		    public void run() {
			try {
				TimeUnit.SECONDS.sleep(3);
				//休眠3秒
			}
			catch (InterruptedException e) {
				System.err.println("線程被中斷" + e.getMessage());
			}
			System.out.println(" 任務(wù)：" + id + "\t 工作線程: "+ Thread.currentThread().getName() + " 執(zhí)行完畢");
		}
	}
}

policy(new ThreadPoolExecutor.AbortPolicy()); 

policy((new ThreadPoolExecutor.CallerRunsPolicy())); 

policy(new ThreadPoolExecutor.DiscardPolicy()); 

policy(new ThreadPoolExecutor.DiscardOldestPolicy());