SQI中@Async异步注解简单使用-阿里云开发者社区

开发者社区> 开发与运维> 正文

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

简介: 最近在Review代码中看到有些同学在使用多线程的时候比较随意,基本上各种使用方式都有。但是有些写法其实是适合standalone的程序,有的写法在Spring中得到了简化。所以建议大家在在SQI相关开发中可以尝试用@Async注解的方式完成异步操作,既清晰明了,也简单方便。 ## 异步的几种写法 + 刀耕火种年代 这个年代是没有线程池管理的,实现了Runnable接口后

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

版权声明:如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:developerteam@list.alibaba-inc.com 进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:

集结各类场景实战经验,助你开发运维畅行无忧

其他文章