spring 的 @Async注解，通过AsyncExecutionInterceptor实现。

/* * Copyright 2002-2013 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * *      http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */package org.springframework.aop.interceptor;import java.lang.reflect.Method;import java.util.concurrent.Callable;import java.util.concurrent.Executor;import java.util.concurrent.Future;import org.aopalliance.intercept.MethodInterceptor;import org.aopalliance.intercept.MethodInvocation;import org.springframework.aop.support.AopUtils;import org.springframework.core.BridgeMethodResolver;import org.springframework.core.Ordered;import org.springframework.core.task.AsyncTaskExecutor;import org.springframework.util.ClassUtils;import org.springframework.util.ReflectionUtils;/** * AOP Alliance {@code MethodInterceptor} that processes method invocations * asynchronously, using a given {@link org.springframework.core.task.AsyncTaskExecutor}. * Typically used with the {@link org.springframework.scheduling.annotation.Async} annotation. * * 
In terms of target method signatures, any parameter types are supported. * However, the return type is constrained to either {@code void} or * {@code java.util.concurrent.Future}. In the latter case, the Future handle * returned from the proxy will be an actual asynchronous Future that can be used * to track the result of the asynchronous method execution. However, since the * target method needs to implement the same signature, it will have to return * a temporary Future handle that just passes the return value through * (like Spring's {@link org.springframework.scheduling.annotation.AsyncResult} * or EJB 3.1's {@code javax.ejb.AsyncResult}). * * 
As of Spring 3.1.2 the {@code AnnotationAsyncExecutionInterceptor} subclass is * preferred for use due to its support for executor qualification in conjunction with * Spring's {@code @Async} annotation. * * @author Juergen Hoeller * @author Chris Beams * @since 3.0 * @see org.springframework.scheduling.annotation.Async * @see org.springframework.scheduling.annotation.AsyncAnnotationAdvisor * @see org.springframework.scheduling.annotation.AnnotationAsyncExecutionInterceptor */public class AsyncExecutionInterceptor extends AsyncExecutionAspectSupport  implements MethodInterceptor, Ordered { /**  * Create a new {@code AsyncExecutionInterceptor}.  * @param executor the {@link Executor} (typically a Spring {@link AsyncTaskExecutor}  * or {@link java.util.concurrent.ExecutorService}) to delegate to.  */ public AsyncExecutionInterceptor(Executor executor) {  super(executor); } /**  * Intercept the given method invocation, submit the actual calling of the method to  * the correct task executor and return immediately to the caller.  * @param invocation the method to intercept and make asynchronous  * @return {@link Future} if the original method returns {@code Future}; {@code null}  * otherwise.  */ public Object invoke(final MethodInvocation invocation) throws Throwable {  Class
      targetClass = (invocation.getThis() != null ? AopUtils.getTargetClass(invocation.getThis()) : null);  Method specificMethod = ClassUtils.getMostSpecificMethod(invocation.getMethod(), targetClass);  specificMethod = BridgeMethodResolver.findBridgedMethod(specificMethod);  AsyncTaskExecutor executor = determineAsyncExecutor(specificMethod);  if (executor == null) {   throw new IllegalStateException(     "No executor specified and no default executor set on AsyncExecutionInterceptor either");  }  Future
      result = executor.submit(    new Callable

   配置task

  在web.xml配置

 
        
        
    
             
     
      org.springframework.web.context.ContextLoaderListener
         
        
    
             
     
      contextConfigLocation
             
     
      classpath*:applicationContext-mybatis.xml,classpath*:applicationContext-task.xml
         
        
        
    
             
     
      dispatcherServlet
             
     
      org.springframework.web.servlet.DispatcherServlet
             
     
                  
      
       contextConfigLocation
                  
      
       classpath*:applicationContext-web.xml
              
             
     
      1
             
     
      true
         
        
    
             
     
      dispatcherServlet
             
     
      /
         
    

   如果出现async失效，则应该注意下task是否放到子context里面去了，应该放到root context声明。

1、controller

 @RequestMapping("/async")    @ResponseBody    public String testAsync(){        for(int i=0;i<10;i++){            asyncService.testAsync();//            asyncService.rightAsync();//            asyncService.poolAsync();        }        logger.info("main end");        return "ok";    }

2、service

package com.yami.service;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.scheduling.annotation.Async;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import org.springframework.stereotype.Service;import javax.annotation.Resource;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * async示例 * @author scipio * @created 2014-03-08 */@Servicepublic class AsyncService {    private static Logger logger = LoggerFactory.getLogger(AsyncService.class);    @Resource    private ProductService productService;    private ExecutorService executor = Executors.newFixedThreadPool(5);    public void poolAsync(){       for(int i=0;i<10;i++){           executor.submit(new Runnable() {               @Override               public void run() {                   oneExecute();               }           });       }    }    private int oneExecute(){        logger.info("I Will be formatting html mail and sending it");        try {            Thread.sleep(5*1000);        } catch (InterruptedException e) {            e.printStackTrace();        }        productService.getProduct("abcd");        logger.info("Asynchronous method call of send email — Complete");        return 1;    }    @Async    public void testAsync(){        oneExecute();    }}