ThreadPoolTaskScheduler 怎么用多线程去跑任务呢

[shayang888]

@Autowired
private ThreadPoolTaskScheduler threadPoolTaskScheduler;

private ScheduledFuture<?> future;

@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
return new ThreadPoolTaskScheduler();
}

传任务的 id，然后开启对应的任务
public void taskStartService(int id){
        try {
            Optional<Task> taskOptional = taskRepository.findById(id);
            if (taskOptional.isPresent()) {
                future = threadPoolTaskScheduler.schedule(() -> {
                        System.out.println("task-" + id + ", " + Thread.currentThread().getName() + "-" + Thread.currentThread().getId());
                        threadMap.put(id, future);
                    }
                }, new CronTrigger(taskOptional.get().getTaskTime()));
    }

然后我启动了 2 个任务，打印出来确实 2 个任务都在运行，但是为什么线程打印出来只有 1 个线程在跑呢

task-1, threadPoolTaskScheduler-1-54
task-2, threadPoolTaskScheduler-1-54

实在是不会了，请大佬给点提示

[wccc]

@Bean(destroyMethod = "shutdown")
public ThreadPoolTaskScheduler scheduledThreadPool() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setThreadNamePrefix("scheduled-thread-");
scheduler.setPoolSize(10);
//等待任务完成后关闭
scheduler.setWaitForTasksToCompleteOnShutdown(true);
//最多等待 60s
scheduler.setAwaitTerminationSeconds(60);
scheduler.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
scheduler.initialize();
return scheduler;
}
定义一个线程池
默认实现只有一个线程的线程池

[shayang888]

@wccc
你好，谢谢大佬，多个线程执行的问题我已经解决了，不过很奇怪为什么我在停止一个任务的时候 发现都停止了，然后我把 future 打印出来 发现是一摸一样的两个 task，这是怎么回事呢
```
task-2, threadPoolTaskScheduler-1-53, DelegatingErrorHandlingRunnable for com.apitest.service.TaskService$$Lambda$1086/0x0000000800a37840@3ebb0180
task-1, threadPoolTaskScheduler-2-78, DelegatingErrorHandlingRunnable for com.apitest.service.TaskService$$Lambda$1086/0x0000000800a37840@3ebb0180
```
这是我启动的两个任务，我在 startService 里打印了这两个 future 为什么这个值是一样的？，这样的话 我如果想停止某个任务，让另一个任务不受影响继续运行该怎么办了

[wccc]

建议打印 task 中执行日志

[shayang888]

@wccc
future = threadPoolTaskScheduler.schedule(() -> {
System.out.println("task-" + id + ", " + Thread.currentThread().getName() + "-" + Thread.currentThread().getId() + ", " + future);
}, new CronTrigger(taskOptional.get().getTaskTime()));
就是这样的，我打印 future 就得到的是一样的，这样我在调用 future.cancel()的时候 整个就停掉了，可是我只想停止单个的

[wccc]

不了解 ThreadPoolTaskScheduler 用于定时任务多线程的
多线程 线程池通常不用这个

[shayang888]

@wccc 确实 我现在就是需要创建不同 cron 的任务来独自运行 或者你有比较好的办法吗

[wccc]

mq 延时消息

[kkjinping]

默认 private volatile int poolSize = 1;

[kkjinping]

需要手动调用 setPoolSize(int size)

[kkjinping]

@shayang888 feature 会不会是因为并发导致的，打印出来的都是最后一个。

[kkjinping]

@shayang888 threadMap.put(id, future);放到 lambda 外面可以吗

[kkjinping]

@shayang888 private ScheduledFuture<?> future; 改成方法内局部变量应该也行

[shayang888]

@kkjinping 哇 谢谢大佬的回复 你有用过这个来做定时任务吗

[shayang888]

@kkjinping 放在局部里不行的 我这后面还有个 stopTaskService(int id) 是用来指定任务的停止的， 不过没按照我的需求生效我不知道为什么
public void taskStopService(int id){
if (taskRepository.findById(id).isPresent()) {
if (future != null) {
future.cancel(true);
}
}

[DsuineGP]

@shayang888 调用 future.cancel 只是向执行任务的线程发送中断指令,具体怎么响应这个指令需要在执行任务的线程中检测并作出相应的处理

[kkjinping]

@shayang888 threadMap.put(id, future); 你不是有这个吗，id 和 future 映射，那你关闭的时候就可以从 map 中拿到 future 了。所以可以把 future 放到局部变量。threadMap 是实例变量。

[shayang888]

@kkjinping 我这么做了 可是并没有用 拿到的 future 在 map 里显示出来是一摸一样的 future.cancel 就全给取消了
{1=DelegatingErrorHandlingRunnable for com.apitest.service.TaskService$$Lambda$1106/0x0000000800a92840@45f08f0a, 2=DelegatingErrorHandlingRunnable for com.apitest.service.TaskService$$Lambda$1106/0x0000000800a92840@45f08f0a}
你看，future 的值是一摸一样的

[kkjinping]

@shayang888 你有改成局部变量吗，future。要两部结合起来。future 放到局部变量。threadMap 是实例变量。

[kkjinping]

@shayang888 threadMap.put(id, future);还要放到 lambda 外面

[kkjinping]

Optional<Task> taskOptional = taskRepository.findById(id);
if (taskOptional.isPresent()) {
future = threadPoolTaskScheduler.schedule(() -> {
System.out.println("task-" + id + ", " + Thread.currentThread().getName() + "-" + Thread.currentThread().getId());

}
}, new CronTrigger(taskOptional.get().getTaskTime()));

threadMap.put(id, future);
}