spring的ThreadPoolTaskExecutor使用可以参考http://kim-miao.iteye.com/blog/1310015。
1.用junit跑测试用例,为什么用ThreadPoolTaskExecutor,里面的代码不执行了。看下下面代码:
private Executor priceSyncExecutor = context.getBean("priceSyncExecutor",Executor.class); try{ for(int i = 0; i < 100;i++) { final int j = i; priceSyncExecutor.execute(new Runnable() { @Override public void run() { method1(j); } }); } Thread.sleep(5000L); }catch(Exception e){ e.printStackTrace(); } public void method1(int i){ try{ Thread.sleep(1000L); System.out.println(i); }catch(Exception e){ e.printStackTrace(); } }
代码比较简单,如果没有主方法的Thread.sleep(5000L),可能一个print都没有打出来。
改变5000L的值,打印的行数也不一样。这个主要是由于executor.execute() 激活的线程都是守护线程,主线程结束,守护线程就会放弃执行,这个在业务中式符合逻辑的,在单元测试中为了看到执行效果,需要自行阻塞主线程,也就是我们这里的sleep 5000L。
顺便说下守护线程,在Java中有两类线程:User Thread(用户线程)、Daemon Thread(守护线程) 在Thanking in java 中说到:
守护线程也叫后台线程,是指在程序中运行的时候在后台提供一种通用服务的线程,并且这种并不属于程序中不可或缺的部分。因此,当所有的非后台线程结束时,程序也就终止了,同时会杀死进程中的所有后台线程。比较常用的是java GC。
相关推荐
本篇文章主要介绍了Spring线程池ThreadPoolTaskExecutor配置详情,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Spring中的同步执行器 ...2.也可以用ThreadPoolTaskExecutor结合FutureTask做到同步。 3.2. SyncTaskExecutor与ThreadPoolTaskExecutor区别 前者是同步执行器,执行任务同步,后者是线程池,执行任务异步。
NULL 博文链接:https://pzzy2000.iteye.com/blog/2434034
MdcThreadPoolTaskExecutor.java
该解决方案的逻辑非常简单,该应用程序使用Spring的@EnableAsync来配置ThreadPoolTaskExecutor ,该ThreadPoolTaskExecutor将用于运行异步方法。 在此应用程序中,使用提供的此ThreadPoolTaskExecutor获取用户及其...
使用spring-redis操作有序集合:opsForZSet().reverseRangeByScoreWithScores使用spring的线程池:org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor使用spring的任务调度:task:scheduled-tasks使
Spring是通过任务执行器(TaskExecutor)来实现多线程和并发编程,使用ThreadPoolTaskExecutor来创建一个基于线城池的TaskExecutor。这篇文章给大家介绍Springboot对多线程的支持,感兴趣的朋友一起看看吧
All Classes AbstractAdvisorAutoProxyCreator AbstractApplicationContext AbstractApplicationEventMulticaster AbstractAspectJAdvice AbstractAspectJAdvisorFactory AbstractAspectJAdvisorFactory....