spring boot异步(Async)任务调度实现方法

package com.chhliu.springboot.jms; 
import org.springframework.jms.annotation.JmsListener; 
import org.springframework.scheduling.annotation.Async; 
import org.springframework.stereotype.Component; 
@Component 
public class Consumer { 
 @JmsListener(destination = "mytest.queue") 
 @Async //该方法会异步执行，也就是说主线程会直接跳过该方法，而是使用线程池中的线程来执行该方法 
 public void receiveQueue(String text) { 
  System.out.println(Thread.currentThread().getName()+":Consumer收到的报文为:"+text); 
 } 
} 

package com.chhliu.springboot.jms; 
import org.springframework.jms.annotation.JmsListener; 
import org.springframework.messaging.handler.annotation.SendTo; 
import org.springframework.stereotype.Component; 
@Component 
public class Consumer2 { 
 @JmsListener(destination = "mytest.queue") 
 @SendTo("out.queue") 
 public String receiveQueue(String text) { 
  System.out.println(Thread.currentThread().getName()+":Consumer2收到的报文为:"+text); 
  return "return message"+text; 
 } 
} 

package com.chhliu.springboot.jms; 
import javax.jms.Destination; 
import org.apache.activemq.command.ActiveMQQueue; 
import org.junit.Test; 
import org.junit.runner.RunWith; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.boot.test.context.SpringBootTest; 
import org.springframework.scheduling.annotation.EnableAsync; 
import org.springframework.test.context.junit4.SpringRunner; 
@RunWith(SpringRunner.class) 
@SpringBootTest 
@EnableAsync // 开启异步任务支持 
public class SpringbootJmsApplicationTests { 
 @Autowired 
 private Producer producer; 
 @Test 
 public void contextLoads() throws InterruptedException { 
  Destination destination = new ActiveMQQueue("mytest.queue"); 
  for(int i=0; i<100; i++){ 
   producer.sendMessage(destination, "myname is chhliu!!!"); 
  } 
 } 
} 

DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! 
SimpleAsyncTaskExecutor-45:Consumer收到的报文为:myname is chhliu!!! 
DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! 
SimpleAsyncTaskExecutor-46:Consumer收到的报文为:myname is chhliu!!! 
DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! 
SimpleAsyncTaskExecutor-47:Consumer收到的报文为:myname is chhliu!!! 
DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! 
SimpleAsyncTaskExecutor-48:Consumer收到的报文为:myname is chhliu!!! 
DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! 
SimpleAsyncTaskExecutor-49:Consumer收到的报文为:myname is chhliu!!! 
DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! 
SimpleAsyncTaskExecutor-50:Consumer收到的报文为:myname is chhliu!!! 
DefaultMessageListenerContainer-1:Consumer2收到的报文为:myname is chhliu!!! 

@Async("taskExecutePool") // 异步任务会提交到taskExecutePool任务池中执行 
 public Future<Response> doSendEmail(MailInfo mailInfo) {// 异步任务返回，使用Future<Response>来异步返回 
  log.info(Thread.currentThread().getName()+"调用了doSendEmail异步方法!"); 
  SendMailSession session = null; 
  Response res = new Response(); 
  boolean isOK = sendEmail(mailInfo);// 具体发邮件的方法 
 if(isOK){   
  res.setSuccess(true);  
 }else{ 
  res.setSuccess(false); 
 } 
 return new AsyncResult<Response>(res); 

Future<Response> result = taskJob.doSendEmail(mailInfo); 
   res = result.get(6, TimeUnit.SECONDS);