视频挺白，机智换手机看

图片很大？ 5M 的网 500K 速度差不多也快到头了

@luob nb

还行

发现工作起来完全重复，找不到一点困难挑战，就跳吧。

什么神奇吗。点击去看了下。没发现 cpu 跑。。

买一筐土豆给他们邮过去，他们肯定屁颠屁颠给你找回

@shayang888 2290968582

@shayang888 是按照我发的写的吗。我打印了不一样啊。

@shayang888 我打印发现不一样呀

并发问题首先要根据具体业务来考虑设计，你可以具体说下某些认为会有问题的场景。

@shayang888 你可以发下代码

@shayang888

@Resource
private ThreadPoolTaskScheduler threadPoolTaskScheduler;

private Map<Integer, Future> futureMap = new HashMap<>(16);

@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler(){
ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
threadPoolTaskScheduler.setPoolSize(10);
return threadPoolTaskScheduler;
}

public void start(int id){
Calendar calendar = Calendar.getInstance();
calendar.add(Calendar.SECOND,5);
ScheduledFuture future = threadPoolTaskScheduler.schedule(() -> {
System.out.println(id + " " + Thread.currentThread().getName());
}, calendar.getTime());
futureMap.put(id,future);
}

public void stop(int id){
Future future = futureMap.get(id);
if(future!=null){
future.cancel(true);
}
}


我试了下没有问题，关闭不壶关全部的

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

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

threadMap.put(id, future);
}

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);
}

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

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

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