spring学习（二十七）--@Async

package springAnnotions;

import java.util.concurrent.Future;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Component;

/**
 * 开发多线程代码，有三种方法
 * 1、实现Runnable接口的run方法
 * 2、继承Thread接口重写run方法
 * 3、使用Callable和Future接口创建线程，这种可以获取返回值
 * 在spring中，使用@Aysnc可以被当作新的多线程方法，被@Aysnc注解的方法再被调用的时候，都会在新的线程中执行。
 * @author qiaozhong
 */
@Component
@EnableAsync
public class AsyncAnnotion {

    /**
     * 无返回值的异步方法
     * @param i
     */
    @Async
    public void asyncTest(String i){
        try {
            System.out.println(i + "start!");
            Thread.sleep(1000);
            System.out.println(i + "end!");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 有返回值的异步方法
     * @param i
     * @return
     */
    @Async
    public Future<String> asyncReturnTest(String i){
        try {
            Thread.sleep(1000);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return new AsyncResult<String>(i);
    }
    
    /**
     * 无返回值的同步方法
     * @param i
     */
    public void notAsyncTest(String i){
        try {
            System.out.println(i + "start!");
            Thread.sleep(1000);
            System.out.println(i + "end!");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    public static void main(String[] args) throws InterruptedException {
        ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("springConfig/spring-all.xml");
        AsyncAnnotion asyncAnnotion = (AsyncAnnotion)ac.getBean(AsyncAnnotion.class);
        for (int i = 0; i < 3; i++) {
            asyncAnnotion.asyncTest(String.valueOf(i));
        }
        
        Thread.sleep(2000);
        
        for (int i = 0; i < 3; i++) {
            asyncAnnotion.notAsyncTest(String.valueOf(i));
        }
        
        Future<String> future;
        future = asyncAnnotion.asyncReturnTest(String.valueOf(5));
        do {
            if (future.isDone()) {
                try {
                    System.out.println(future.get());
                    break;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        } while (true);
    }
    
}