最近在Review代码中看到有些同学在使用多线程的时候比较随意，基本上各种使用方式都有。但是有些写法其实是适合standalone的程序，有的写法在Spring中得到了简化。所以建议大家在在SQI相关开发中可以尝试用@Async注解的方式完成异步操作，既清晰明了，也简单方便。
异步的几种写法
- 刀耕火种年代
这个年代是没有线程池管理的，实现了Runnable接口后就start来运行。
-
大航海时代
这个年代已经开始使用线程池了，我们可以看一段示例代码
ExecutorService executor = Executors.newFixedThreadPool(N); for (int i = 0; i < kProducts.size(); i++) { Products product = kProducts.get(i); if (pid != null || bizdate != null) { if (bizdate == null) { bizdate = "2015-04-01"; } executor.execute(new offlineKeludeJob(product, DateUtils.getMorning(DateUtils.parseDate(bizdate)))); } else { executor.execute(new offlineKeludeJob(product)); } } executor.shutdown();这段代码在standalone程序中看起来问题不大。但是在Web服务中每个Request都会来调用一次，会使得堆积的请求处理队列消耗非常大的内存，极端情况下会引发OOM问题。
- 工业化时代
在这里大家使用Spring中的ThreadPoolTaskExecutor，使用起来也没有特别大的问题。例如下面这个简单的例子
<task:executor id="labelTaskExecutor" pool-size="100" queue-capacity="10000" rejection-policy="ABORT"/> @Autowired
ThreadPoolTaskExecutor labelDbExecutor;
labelTaskExecutor.submit(new Runnable() {
@Override
public void run() {
try {
Integer ret = insert(tmpLabelData);
if (ret <= 0) {
logger.error(String.format("[ERRORLabelData]insert data failed! label data:%s", JSONObject.toJSONString(tmpLabelData)));
}
} catch (Exception e) {
logger.error(String.format("[ERRORLabelData]insert data into db exception!"), e);
}
}
}
);@Async注解使用
上面说了那么多用户，其实都没有什么用。只是用来突出关于Async注解的使用。最初的两种方法都因为自身的不足，不建议在SQI项目中直接使用。而最后一个方法虽然没有什么问题，但是写起来比较麻烦，还需要自己实现Runnable接口。那么对于我们来说，有没有更简单方便的方式来使用呢？答案就是Spring 3.0带来Async注解，其使用主要就只有两步。
-
在applicationContext.xml中增加线程池配置
<context:component-scan base-package="com.alibaba.search" /> <task:annotation-driven executor="defaultExecutor"/> <task:executor id="defaultExecutor" pool-size="100" queue-capacity="10000" rejection-policy="ABORT"/> -
在你需要调用的方法上加上相应的注解
@Service public class TestClass { @Async public void asyncTest() { //Do something } }
@Async使用注意事项
- 类内部的方法间的调用是不起效果的，具体是在于Async是基于bean自动扫描后生成的proxy实现的。那么一定要用怎么办，最简单的办法就是拆出到另外一个class里面。
-
如果在多个XML中进行了配置是会覆盖的。例如SQI在web.xml中定义了
<servlet> <servlet-name>spring</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:springMvcConfig.xml</param-value> </init-param> <load-on-startup>2</load-on-startup> </servlet>
那么如果同时在springMvcConfig.xml和applicationContext.xml中有对task:executor的定义的话，DispatcherServlet中加载的XML会覆盖掉ContextLoaderListener中加载的。用我们的例子来讲就是springMvcConfig.xml中的配置会覆盖掉applicationContext.xml。
-
如果要使用多个线程池怎么办？在使用的时候指定一下对应的ID就可以了。
<context:component-scan base-package="com.alibaba.search" /> <task:annotation-driven executor="defaultExecutor"/> <task:executor id="defaultExecutor" pool-size="100" queue-capacity="10000" rejection-policy="ABORT"/> <task:executor id="statisticExecutor" pool-size="100" queue-capacity="10000" rejection-policy="ABORT"/>
@Service
public class TestClass {
@Async
public void asyncTest() {
//Do something
}
@Async("statisticExecutor")
public void statisticAsyncTest() {
//Do some statistic
}
}
