自定义线程池使用案例

自定义线程池使用案例

public void testThreadPool(){
	//ThreadPoolExecutor.AbortPolicy abortPolicy = new ThreadPoolExecutor.AbortPolicy();
		new ThreadPoolExecutor(3,5,5,
			TimeUnit.SECONDS,
			new ArrayBlockingQueue<Runnable>(10),
			Executors.defaultThreadFactory(),new aa());
}

class aa extends ThreadPoolExecutor.AbortPolicy {
	@Override
	public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
		System.out.println("抛出异常，记录日志");
		super.rejectedExecution(r, e);
	}
}