- 一、线程池配置
- properties配置文件
- 加载线程池参数配置类
- 二、异步方法编写
- 三、测试异步方法
- 测试类
- 查看任务状态
- 状态码
- 测试结果
- result1
- result2
- 四、问题
- 队列满了抛异常
- 解决方法
- 1.增大队列值
- 2.ThreadPoolExecutor 指定拒绝方式
- 2.1 AbortPolicy(默认)
- 2.2 CallerRunsPolicy
- 2.3 DiscardPolicy 抛弃
- 2.4 DiscardOldestPolicy 抛弃之前的任务
- 五、其他
- FutureTask源码
- 总任务数量改成5000结果
#Thread thread_core_pool_size=500 thread_max_pool_size=500 thread_queue_size=500 thread_prefix_name=test加载线程池参数配置类
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@Configuration
@PropertySource(value = "classpath:data-service.properties")
public class ThreadPoolConfig {
@Value("${thread_core_pool_size}")
private int coreSize;
@Value("${thread_max_pool_size}")
private int maxSize;
@Value("${thread_queue_size}")
private int queueSize;
@Value("${thread_prefix_name}")
private String prefixNm;
@Bean
public ThreadPoolTaskExecutor defaultThreadPool() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//核心线程数目
executor.setCorePoolSize(coreSize);
//指定最大线程数
executor.setMaxPoolSize(maxSize);
//队列中最大的数目
executor.setQueueCapacity(queueSize);
//线程名称前缀
executor.setThreadNamePrefix(prefixNm);
//线程空闲后的最大存活时间 ，默认是60秒
executor.setKeepAliveSeconds(90);
//加载
executor.initialize();
return executor;
}
}
二、异步方法编写
import java.util.concurrent.Callable;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@Component
public class AsynTaskFature {
@Async
public Callable task(String taskName) throws Exception {
Callable result = new Callable() {
@Override
public String call() throws Exception {
//TODO 具体逻辑处理
if(taskName.contains("1")||taskName.contains("3")||taskName.contains("5")) {
Thread.sleep(100000);
}else {
Thread.sleep(1000);
}
return "SUCC";
}
};
return result;
}
}
三、测试异步方法
测试类
使用的定时任务，每三秒跑一次（上一次任务完成后，间隔三秒，开始下一次任务）
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.FutureTask;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;
@Slf4j
@Component
@EnableScheduling
public class ThreadTest {
private static final int batchSize = 500;//批处理数量
@Autowired
AsynTaskFature asynTaskFature;
@Autowired
ThreadPoolConfig thread;
@Scheduled(cron = "3 * * * * *")
public void testFutureTask() throws Exception {
log.info("testFutureTask start ==============================");
FutureTask futureTask = null;
long startTime= System.currentTimeMillis()/1000;
for(int j=0;j<2000;j++) {
long startTaskTime= System.currentTimeMillis()/1000;
List> fList= new ArrayList<>();
for(int i=j;i(asynTaskFature.task("task-"+i));
ThreadPoolTaskExecutor executor = thread.defaultThreadPool();
executor.execute(futureTask); // 执行任务
fList.add(futureTask);
}
boolean rst = true;
while (rst) {// 等待所有任务都执行结束
boolean count = true;
for(FutureTask f:fList) {
if(!f.isDone()) {
Thread.sleep(10000);
count=false;
break;
}
}
log.info("testFutureTask ["+j+","+(j+batchSize)+"] is processing");
if(count) {
rst = false;
}
}
log.info("testFutureTask ["+j+","+(j+batchSize)+"] finish，spend time "+(System.currentTimeMillis()/1000 -startTaskTime)+" s");
j+=(batchSize-1);
}
log.info("testFutureTask all end,spend time "+(System.currentTimeMillis()/1000 -startTime)+" s");
}
}
查看任务状态
通过断点查看，任务task1、3、5…设置休眠时间比较长，所以一开始处于新建状态-0，而休眠时间短的任务状态已正常结束-2
private static final int NEW = 0; //任务新建和执行中 private static final int COMPLETING = 1; //任务将要执行完毕 private static final int NORMAL = 2; //任务正常执行结束 private static final int EXCEPTIonAL = 3; //任务异常 private static final int CANCELLED = 4; //任务取消 private static final int INTERRUPTING = 5; //任务线程即将被中断 private static final int INTERRUPTED = 6; //任务线程已中断测试结果 result1
总任务2000，每次处理500条
2021-10-10 16:02:03.003 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 16:02:13.035 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:02:23.035 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:02:33.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:02:43.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:02:53.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:03.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:13.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:23.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:33.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:43.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:43.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] is processing 2021-10-10 16:03:43.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,500] finish，spend time 100 s 2021-10-10 16:03:53.040 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:04:03.041 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:04:13.041 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:04:23.041 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:04:33.042 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:04:43.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:04:53.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:05:03.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:05:13.044 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:05:23.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:05:33.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:05:33.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] is processing 2021-10-10 16:05:33.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [500,1000] finish，spend time 110 s 2021-10-10 16:05:33.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,1500] is processing 2021-10-10 16:05:33.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,1500] finish，spend time 0 s 2021-10-10 16:05:33.064 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1500,2000] is processing 2021-10-10 16:05:33.064 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1500,2000] finish，spend time 0 s 2021-10-10 16:05:33.064 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask all end,spend time 210 sresult2
总任务2000，每次处理1000条（batchSize 改为10000）
2021-10-10 15:36:03.001 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 15:36:13.083 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:36:23.083 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:36:33.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:36:43.087 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:36:53.087 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:37:03.088 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:37:13.088 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:37:23.089 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:37:33.089 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:37:43.090 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:37:53.090 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:38:03.090 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:38:13.091 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:38:23.091 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:38:33.092 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:38:43.092 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:38:53.092 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:39:03.093 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:39:13.093 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:39:23.093 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:39:23.093 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 15:39:23.093 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] finish，spend time 200 s 2021-10-10 15:39:23.094 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 15:39:23.094 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] finish，spend time 0 s 2021-10-10 15:39:23.094 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask all end,spend time 200 s四、问题 队列满了抛异常
结果2跑成功后，紧接着进行下一次，结果报了下面错，队列满了，抛异常（默认的拒绝方式）
2021-10-10 15:40:03.011 [scheduling-1] ERROR o.s.s.support.TaskUtils$LoggingErrorHandler - Unexpected error occurred in scheduled task. org.springframework.core.task.TaskRejectedException: Executor [java.util.concurrent.ThreadPoolExecutor@1591982c[Running, pool size = 500, active threads = 54, queued tasks = 478, completed tasks = 1000]] did not accept task: java.util.concurrent.FutureTask@2b0b9e49 at org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:317) at com.copote.data.manager.metabase.service.thread.ThreadTest.testFutureTask(ThreadTest.java:37) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:84) at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:93) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@2b0b9e49 rejected from java.util.concurrent.ThreadPoolExecutor@1591982c[Running, pool size = 500, active threads = 43, queued tasks = 490, completed tasks = 1000] at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047) at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823) at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369) at org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:314) ... 15 common frames omitted解决方法 1.增大队列值
定时任务执行第二遍的时候不报错了，结果如下：
2021-10-10 16:10:03.002 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 16:10:13.047 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:10:23.048 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:10:33.048 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:10:43.048 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:10:53.048 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:11:03.049 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:11:13.049 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:11:23.049 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:11:33.049 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:11:43.050 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:11:53.050 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:12:03.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:12:13.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:12:23.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:12:33.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:12:43.052 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:12:53.052 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:13:03.052 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:13:13.053 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:13:23.053 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:13:23.053 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:13:23.054 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] finish，spend time 200 s 2021-10-10 16:13:23.054 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:13:23.054 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] finish，spend time 0 s 2021-10-10 16:13:23.054 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask all end,spend time 200 s 2021-10-10 16:14:03.001 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 16:14:13.005 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:14:23.005 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:14:33.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:14:43.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:14:53.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:15:03.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:15:13.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:15:23.007 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:15:33.007 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:15:43.008 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:15:53.008 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:16:03.009 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:16:13.009 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:16:23.010 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:16:33.010 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:16:43.011 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:16:53.011 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:17:03.011 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:17:13.012 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:17:23.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:17:33.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:17:33.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:17:33.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] finish，spend time 210 s 2021-10-10 16:17:33.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:17:33.020 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] finish，spend time 0 s 2021-10-10 16:17:33.020 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask all end,spend time 210 s2.ThreadPoolExecutor 指定拒绝方式 2.1 AbortPolicy(默认)
直接抛异常RejectedExecutionException…
2.2 CallerRunsPolicy会调用当前线程池的所在的线程去执行被拒绝的任务,但是会阻塞主线程。
2.3 DiscardPolicy 抛弃抛弃策略，会让被线程池拒绝的任务直接抛弃，不会抛异常也不会执行。
2.4 DiscardOldestPolicy 抛弃之前的任务会抛弃任务队列中最旧的任务也就是最先加入队列的，再把这个新任务添加进去
指定代码，以2.2为例
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());五、其他 FutureTask源码
package java.util.concurrent; import java.util.concurrent.locks.LockSupport; public class FutureTask总任务数量改成5000结果implements RunnableFuture { private volatile int state; private static final int NEW = 0; private static final int COMPLETING = 1; private static final int NORMAL = 2; private static final int EXCEPTIonAL = 3; private static final int CANCELLED = 4; private static final int INTERRUPTING = 5; private static final int INTERRUPTED = 6; private Callable callable; private Object outcome; // non-volatile, protected by state reads/writes private volatile Thread runner; private volatile WaitNode waiters; @SuppressWarnings("unchecked") private V report(int s) throws ExecutionException { Object x = outcome; if (s == NORMAL) return (V)x; if (s >= CANCELLED) throw new CancellationException(); throw new ExecutionException((Throwable)x); } public FutureTask(Callable callable) { if (callable == null) throw new NullPointerException(); this.callable = callable; this.state = NEW; // ensure visibility of callable } public FutureTask(Runnable runnable, V result) { this.callable = Executors.callable(runnable, result); this.state = NEW; // ensure visibility of callable } public boolean isCancelled() { return state >= CANCELLED; } public boolean isDone() { return state != NEW; } public boolean cancel(boolean mayInterruptIfRunning) { if (!(state == NEW && UNSAFE.compareAndSwapInt(this, stateOffset, NEW, mayInterruptIfRunning ? INTERRUPTING : CANCELLED))) return false; try { // in case call to interrupt throws exception if (mayInterruptIfRunning) { try { Thread t = runner; if (t != null) t.interrupt(); } finally { // final state UNSAFE.putOrderedInt(this, stateOffset, INTERRUPTED); } } } finally { finishCompletion(); } return true; } public V get() throws InterruptedException, ExecutionException { int s = state; if (s <= COMPLETING) s = awaitDone(false, 0L); return report(s); } public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { if (unit == null) throw new NullPointerException(); int s = state; if (s <= COMPLETING && (s = awaitDone(true, unit.tonanos(timeout))) <= COMPLETING) throw new TimeoutException(); return report(s); } protected void done() { } protected void set(V v) { if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) { outcome = v; UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state finishCompletion(); } } protected void setException(Throwable t) { if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) { outcome = t; UNSAFE.putOrderedInt(this, stateOffset, EXCEPTIONAL); // final state finishCompletion(); } } public void run() { if (state != NEW || !UNSAFE.compareAndSwapObject(this, runnerOffset, null, Thread.currentThread())) return; try { Callable c = callable; if (c != null && state == NEW) { V result; boolean ran; try { result = c.call(); ran = true; } catch (Throwable ex) { result = null; ran = false; setException(ex); } if (ran) set(result); } } finally { // runner must be non-null until state is settled to // prevent concurrent calls to run() runner = null; // state must be re-read after nulling runner to prevent // leaked interrupts int s = state; if (s >= INTERRUPTING) handlePossibleCancellationInterrupt(s); } } protected boolean runAndReset() { if (state != NEW || !UNSAFE.compareAndSwapObject(this, runnerOffset, null, Thread.currentThread())) return false; boolean ran = false; int s = state; try { Callable c = callable; if (c != null && s == NEW) { try { c.call(); // don't set result ran = true; } catch (Throwable ex) { setException(ex); } } } finally { // runner must be non-null until state is settled to // prevent concurrent calls to run() runner = null; // state must be re-read after nulling runner to prevent // leaked interrupts s = state; if (s >= INTERRUPTING) handlePossibleCancellationInterrupt(s); } return ran && s == NEW; } private void handlePossibleCancellationInterrupt(int s) { // It is possible for our interrupter to stall before getting a // chance to interrupt us. Let's spin-wait patiently. if (s == INTERRUPTING) while (state == INTERRUPTING) Thread.yield(); // wait out pending interrupt // assert state == INTERRUPTED; // We want to clear any interrupt we may have received from // cancel(true). However, it is permissible to use interrupts // as an independent mechanism for a task to communicate with // its caller, and there is no way to clear only the // cancellation interrupt. // // Thread.interrupted(); } static final class WaitNode { volatile Thread thread; volatile WaitNode next; WaitNode() { thread = Thread.currentThread(); } } private void finishCompletion() { // assert state > COMPLETING; for (WaitNode q; (q = waiters) != null;) { if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null)) { for (;;) { Thread t = q.thread; if (t != null) { q.thread = null; LockSupport.unpark(t); } WaitNode next = q.next; if (next == null) break; q.next = null; // unlink to help gc q = next; } break; } } done(); callable = null; // to reduce footprint } private int awaitDone(boolean timed, long nanos) throws InterruptedException { final long deadline = timed ? System.nanoTime() + nanos : 0L; WaitNode q = null; boolean queued = false; for (;;) { if (Thread.interrupted()) { removeWaiter(q); throw new InterruptedException(); } int s = state; if (s > COMPLETING) { if (q != null) q.thread = null; return s; } else if (s == COMPLETING) // cannot time out yet Thread.yield(); else if (q == null) q = new WaitNode(); else if (!queued) queued = UNSAFE.compareAndSwapObject(this, waitersOffset, q.next = waiters, q); else if (timed) { nanos = deadline - System.nanoTime(); if (nanos <= 0L) { removeWaiter(q); return state; } LockSupport.parkNanos(this, nanos); } else LockSupport.park(this); } } private void removeWaiter(WaitNode node) { if (node != null) { node.thread = null; retry: for (;;) { // restart on removeWaiter race for (WaitNode pred = null, q = waiters, s; q != null; q = s) { s = q.next; if (q.thread != null) pred = q; else if (pred != null) { pred.next = s; if (pred.thread == null) // check for race continue retry; } else if (!UNSAFE.compareAndSwapObject(this, waitersOffset, q, s)) continue retry; } break; } } } // Unsafe mechanics private static final sun.misc.Unsafe UNSAFE; private static final long stateOffset; private static final long runnerOffset; private static final long waitersOffset; static { try { UNSAFE = sun.misc.Unsafe.getUnsafe(); Class k = FutureTask.class; stateOffset = UNSAFE.objectFieldOffset (k.getDeclaredField("state")); runnerOffset = UNSAFE.objectFieldOffset (k.getDeclaredField("runner")); waitersOffset = UNSAFE.objectFieldOffset (k.getDeclaredField("waiters")); } catch (Exception e) { throw new Error(e); } } }
2021-10-10 16:34:03.001 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 16:34:13.035 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:34:23.035 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:34:33.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:34:43.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:34:53.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:35:03.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:35:13.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:35:23.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:35:33.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:35:43.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:35:53.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:36:03.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:36:13.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:36:23.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:36:33.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:36:43.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:36:53.040 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:37:03.040 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:37:13.041 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:37:23.044 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:37:23.044 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:37:23.044 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] finish，spend time 200 s 2021-10-10 16:37:33.050 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:37:43.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:37:53.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:38:03.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:38:13.051 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:38:23.052 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:38:33.053 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:38:43.053 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:38:53.054 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:39:03.054 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:39:13.055 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:39:23.055 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:39:33.055 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:39:43.055 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:39:53.055 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:03.056 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:13.057 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:23.057 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:33.057 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:43.058 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:43.058 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:40:43.058 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] finish，spend time 200 s 2021-10-10 16:40:53.062 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:41:03.062 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:41:13.063 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:41:23.064 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:41:33.065 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:41:43.065 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:41:53.066 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:42:03.066 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:42:13.066 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:42:23.067 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:42:33.069 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:42:43.069 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:42:53.070 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:43:03.071 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:43:13.071 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:43:23.072 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:43:33.072 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:43:43.073 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:43:53.073 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:44:03.074 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:44:03.074 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:44:03.074 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] finish，spend time 200 s 2021-10-10 16:44:13.077 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:44:23.078 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:44:33.078 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:44:43.078 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:44:53.079 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:45:03.079 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:45:13.080 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:45:23.080 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:45:33.081 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:45:43.081 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:45:53.081 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:46:03.081 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:46:13.082 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:46:23.083 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:46:33.083 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:46:43.083 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:46:53.084 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:47:03.084 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:47:13.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:47:23.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:47:23.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:47:23.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] finish，spend time 200 s 2021-10-10 16:47:23.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [4000,5000] is processing 2021-10-10 16:47:23.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [4000,5000] finish，spend time 0 s 2021-10-10 16:47:23.085 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask all end,spend time 800 s 2021-10-10 16:48:03.002 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 16:48:33.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:48:43.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:48:53.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:49:03.006 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:49:13.007 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:49:23.008 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:49:33.009 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:49:43.010 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:49:53.010 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:50:03.010 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:50:13.010 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:50:23.011 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:50:33.011 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:50:43.012 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:50:53.013 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:51:03.013 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:51:13.014 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:51:23.014 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:51:23.014 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing 2021-10-10 16:51:23.014 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] finish，spend time 200 s 2021-10-10 16:51:33.015 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:51:43.016 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:51:53.016 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:52:03.017 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:52:13.017 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:52:23.017 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:52:33.018 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:52:43.018 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:52:53.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:53:03.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:53:13.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:53:23.019 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:53:33.020 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:53:43.020 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:53:53.020 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:03.020 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:13.021 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:23.021 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:33.022 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:43.023 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:43.023 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] is processing 2021-10-10 16:54:43.023 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [1000,2000] finish，spend time 200 s 2021-10-10 16:54:53.025 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:55:03.025 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:55:13.026 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:55:23.026 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:55:33.026 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:55:43.027 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:55:53.027 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:56:03.028 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:56:13.028 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:56:23.028 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:56:33.029 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:56:43.029 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:56:53.029 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:57:03.029 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:57:13.030 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:57:23.030 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:57:33.031 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:57:43.031 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:57:53.031 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:58:03.031 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:58:03.031 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] is processing 2021-10-10 16:58:03.031 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [2000,3000] finish，spend time 200 s 2021-10-10 16:58:13.034 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:58:23.034 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:58:33.034 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:58:43.035 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:58:53.035 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:59:03.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:59:13.036 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:59:23.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:59:33.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:59:43.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 16:59:53.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:00:03.037 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:00:13.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:00:23.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:00:33.038 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:00:43.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:00:53.039 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:01:03.040 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:01:13.041 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:01:23.041 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:01:33.042 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:01:33.042 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] is processing 2021-10-10 17:01:33.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [3000,4000] finish，spend time 210 s 2021-10-10 17:01:33.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [4000,5000] is processing 2021-10-10 17:01:33.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [4000,5000] finish，spend time 0 s 2021-10-10 17:01:33.043 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask all end,spend time 810 s 2021-10-10 17:02:03.001 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask start ============================== 2021-10-10 17:02:13.003 [scheduling-1] INFO c.c.d.manager.metabase.service.thread.ThreadTest - testFutureTask [0,1000] is processing
