FutureTask批量判断结果
一、线程池配置
properties配置文件
#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;
/**.
* 默认线程池
*
* @return Executor
*/
@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<String> task(String taskName) throws Exception {
Callable<String> result = new Callable<String>() {
@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<String> futureTask = null;
long startTime= System.currentTimeMillis()/1000;
for(int j=0;j<2000;j++) {
long startTaskTime= System.currentTimeMillis()/1000;
List<FutureTask<String>> fList= new ArrayList<>();
for(int i=j;i<j+batchSize && j+batchSize<1500;i++) {
futureTask = new FutureTask<String>(asynTaskFature.task("task-"+i));
ThreadPoolTaskExecutor executor = thread.defaultThreadPool();
executor.execute(futureTask); // 执行任务
fList.add(futureTask);
}
boolean rst = true;
while (rst) {// 等待所有任务都执行结束
boolean count = true;
for(FutureTask<String> 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源码
/*
* ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
* Written by Doug Lea with assistance from members of JCP JSR-166
* Expert Group and released to the public domain, as explained at
* http://creativecommons.org/publicdomain/zero/1.0/
*/
package java.util.concurrent;
import java.util.concurrent.locks.LockSupport;
/**
* A cancellable asynchronous computation. This class provides a base
* implementation of {@link Future}, with methods to start and cancel
* a computation, query to see if the computation is complete, and
* retrieve the result of the computation. The result can only be
* retrieved when the computation has completed; the {@code get}
* methods will block if the computation has not yet completed. Once
* the computation has completed, the computation cannot be restarted
* or cancelled (unless the computation is invoked using
* {@link #runAndReset}).
*
* <p>A {@code FutureTask} can be used to wrap a {@link Callable} or
* {@link Runnable} object. Because {@code FutureTask} implements
* {@code Runnable}, a {@code FutureTask} can be submitted to an
* {@link Executor} for execution.
*
* <p>In addition to serving as a standalone class, this class provides
* {@code protected} functionality that may be useful when creating
* customized task classes.
*
* @since 1.5
* @author Doug Lea
* @param <V> The result type returned by this FutureTask's {@code get} methods
*/
public class FutureTask<V> implements RunnableFuture<V> {
/*
* Revision notes: This differs from previous versions of this
* class that relied on AbstractQueuedSynchronizer, mainly to
* avoid surprising users about retaining interrupt status during
* cancellation races. Sync control in the current design relies
* on a "state" field updated via CAS to track completion, along
* with a simple Treiber stack to hold waiting threads.
*
* Style note: As usual, we bypass overhead of using
* AtomicXFieldUpdaters and instead directly use Unsafe intrinsics.
*/
/**
* The run state of this task, initially NEW. The run state
* transitions to a terminal state only in methods set,
* setException, and cancel. During completion, state may take on
* transient values of COMPLETING (while outcome is being set) or
* INTERRUPTING (only while interrupting the runner to satisfy a
* cancel(true)). Transitions from these intermediate to final
* states use cheaper ordered/lazy writes because values are unique
* and cannot be further modified.
*
* Possible state transitions:
* NEW -> COMPLETING -> NORMAL
* NEW -> COMPLETING -> EXCEPTIONAL
* NEW -> CANCELLED
* NEW -> INTERRUPTING -> INTERRUPTED
*/
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;
/** The underlying callable; nulled out after running */
private Callable<V> callable;
/** The result to return or exception to throw from get() */
private Object outcome; // non-volatile, protected by state reads/writes
/** The thread running the callable; CASed during run() */
private volatile Thread runner;
/** Treiber stack of waiting threads */
private volatile WaitNode waiters;
/**
* Returns result or throws exception for completed task.
*
* @param s completed state value
*/
@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);
}
/**
* Creates a {@code FutureTask} that will, upon running, execute the
* given {@code Callable}.
*
* @param callable the callable task
* @throws NullPointerException if the callable is null
*/
public FutureTask(Callable<V> callable) {
if (callable == null)
throw new NullPointerException();
this.callable = callable;
this.state = NEW; // ensure visibility of callable
}
/**
* Creates a {@code FutureTask} that will, upon running, execute the
* given {@code Runnable}, and arrange that {@code get} will return the
* given result on successful completion.
*
* @param runnable the runnable task
* @param result the result to return on successful completion. If
* you don't need a particular result, consider using
* constructions of the form:
* {@code Future<?> f = new FutureTask<Void>(runnable, null)}
* @throws NullPointerException if the runnable is null
*/
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;
}
/**
* @throws CancellationException {@inheritDoc}
*/
public V get() throws InterruptedException, ExecutionException {
int s = state;
if (s <= COMPLETING)
s = awaitDone(false, 0L);
return report(s);
}
/**
* @throws CancellationException {@inheritDoc}
*/
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 method invoked when this task transitions to state
* {@code isDone} (whether normally or via cancellation). The
* default implementation does nothing. Subclasses may override
* this method to invoke completion callbacks or perform
* bookkeeping. Note that you can query status inside the
* implementation of this method to determine whether this task
* has been cancelled.
*/
protected void done() { }
/**
* Sets the result of this future to the given value unless
* this future has already been set or has been cancelled.
*
* <p>This method is invoked internally by the {@link #run} method
* upon successful completion of the computation.
*
* @param v the value
*/
protected void set(V v) {
if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
outcome = v;
UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state
finishCompletion();
}
}
/**
* Causes this future to report an {@link ExecutionException}
* with the given throwable as its cause, unless this future has
* already been set or has been cancelled.
*
* <p>This method is invoked internally by the {@link #run} method
* upon failure of the computation.
*
* @param t the cause of failure
*/
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<V> 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);
}
}
/**
* Executes the computation without setting its result, and then
* resets this future to initial state, failing to do so if the
* computation encounters an exception or is cancelled. This is
* designed for use with tasks that intrinsically execute more
* than once.
*
* @return {@code true} if successfully run and reset
*/
protected boolean runAndReset() {
if (state != NEW ||
!UNSAFE.compareAndSwapObject(this, runnerOffset,
null, Thread.currentThread()))
return false;
boolean ran = false;
int s = state;
try {
Callable<V> 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;
}
/**
* Ensures that any interrupt from a possible cancel(true) is only
* delivered to a task while in run or runAndReset.
*/
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();
}
/**
* Simple linked list nodes to record waiting threads in a Treiber
* stack. See other classes such as Phaser and SynchronousQueue
* for more detailed explanation.
*/
static final class WaitNode {
volatile Thread thread;
volatile WaitNode next;
WaitNode() { thread = Thread.currentThread(); }
}
/**
* Removes and signals all waiting threads, invokes done(), and
* nulls out callable.
*/
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
}
/**
* Awaits completion or aborts on interrupt or timeout.
*
* @param timed true if use timed waits
* @param nanos time to wait, if timed
* @return state upon completion
*/
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);
}
}
/**
* Tries to unlink a timed-out or interrupted wait node to avoid
* accumulating garbage. Internal nodes are simply unspliced
* without CAS since it is harmless if they are traversed anyway
* by releasers. To avoid effects of unsplicing from already
* removed nodes, the list is retraversed in case of an apparent
* race. This is slow when there are a lot of nodes, but we don't
* expect lists to be long enough to outweigh higher-overhead
* schemes.
*/
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);
}
}
}总任务数量改成5000结果
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 p