自定义线程池有界队列拒绝策略RejectedExecutionHandler

package cm.pool;

public class MyTask implements Runnable {

private int taskId;
private String taskName;

public MyTask(int taskId, String taskName) {
this.taskId = taskId;
this.taskName = taskName;
}
public int getTaskId() {
return taskId;
}
public void setTaskId(int taskId) {
this.taskId = taskId;
}

public String getTaskName() {
return taskName;
}
public void setTaskName(String taskName) {
this.taskName = taskName;
}

@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName()+"-----------run taskId="+this.taskId);
Thread.sleep(5*1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Override
public String toString() {
return "MyTask [taskId=" + taskId + ", taskName=" + taskName + "]";
}
}

package cm.pool;

import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;

public class MyRejected implements RejectedExecutionHandler {

@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
System.out.println("自定义拒绝策略.....");
System.out.println("当前被拒绝的任务------"+Thread.currentThread().getName()+":"+r.toString());
}

}

package cm.pool;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* @author Administrator
* 1.使用有界队列时，若有新的任务执行，如果线程池实际线程不小于corsize，则优先创建线程。
* 2.若大于corsize，则将任务加入到队列中，等待第一个任务执行完成之后在执行队列里的任务。
* 3.若队列中的任务已满，则在总线程数不大于maxsize前提下，创建一个新的线程(此时已经创建两个线程先执行了两次任务，然后执行队列里存放了的三个任务)
* 4.若线程数大于maxsize，则执行拒绝策略，获取其他自定义方法。
*/
public class UseThreadpoolExecutor_1 {
public static void main(String[] args) {
ThreadPoolExecutor pool = new ThreadPoolExecutor(1, // corSize
2, // maxPoolSize
60, // keepAliveTime
TimeUnit.SECONDS, // unit,
new ArrayBlockingQueue<Runnable>(3),// workQueue
new MyRejected()
);
MyTask task1 = new MyTask(1, "任务1");
MyTask task2 = new MyTask(2, "任务2");
MyTask task3 = new MyTask(3, "任务3");
MyTask task4 = new MyTask(4, "任务4");
MyTask task5 = new MyTask(5, "任务5");
MyTask task6 = new MyTask(6, "任务6");

pool.execute(task1);
//2、3、4会放到队列
pool.execute(task2);
pool.execute(task3);
pool.execute(task4);
pool.execute(task5);
pool.execute(task6);
pool.shutdown();
}
}

pool-1-thread-2-----------run taskId=5
自定义拒绝策略.....
pool-1-thread-1-----------run taskId=1
当前被拒绝的任务------main:MyTask [taskId=6, taskName=任务6]
pool-1-thread-2-----------run taskId=2
pool-1-thread-1-----------run taskId=3
pool-1-thread-1-----------run taskId=4