SQI中@Async异步注解简单使用

最近在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
  }
}

异步的几种写法

@Async注解使用

@Async使用注意事项

Leave a Reply Cancel reply