浅谈Java中spring 线程异步执行

@Configuration
public class WebMvcConfigurerAdpter extends AbstractWebMvcConfigurerAdpter {

 @Override
 public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
  super.configureMessageConverters(converters);
  WafJsonMapper.getMapper().enable(DeserializationFeature.FAIL_ON_NUMBERS_FOR_ENUMS);
 }


 @Bean
 public TaskExecutor taskExecutor() {
  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
  executor.setCorePoolSize(5);
  executor.setMaxPoolSize(10);
  return executor;
 }
}

@Service
public class TaskService {

 @Autowired
 private TaskExecutor executor;

 public void execute() {
  executor.execute(new Runnable() {
   @Override
   public void run() {
    for (int i = 0; i < 10; i++) {
     try {
      Thread.sleep(1000);
      System.out.println("task running ...");
     } catch (Exception e) {

     }
    }
   }
  });
 }
}

@RestController
@RequestMapping(value = "/v0.1")
public class TaskController {

 @Autowired
 private TaskService taskService;

 @RequestMapping()
 public Object execute() {
  taskService.execute();
  Map res = new HashMap();
  res.put("result", "success");
  return res;
 }
}

ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
//线程池所使用的缓冲队列
poolTaskExecutor.setQueueCapacity(200);
//线程池维护线程的最少数量
poolTaskExecutor.setCorePoolSize(5);
//线程池维护线程的最大数量
poolTaskExecutor.setMaxPoolSize(1000);
//线程池维护线程所允许的空闲时间
poolTaskExecutor.setKeepAliveSeconds(30000);
poolTaskExecutor.initialize();

<!-- 配置线程池 -->
<bean id ="taskExecutor" class ="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" >
 <!-- 线程池维护线程的最少数量 -->
<span style="white-space:pre"> </span><property name ="corePoolSize" value ="5" />
 <!-- 线程池维护线程所允许的空闲时间 -->
<span style="white-space:pre"> </span><property name ="keepAliveSeconds" value ="30000" />
 <!-- 线程池维护线程的最大数量 -->
<span style="white-space:pre"> </span><property name ="maxPoolSize" value ="1000" />
 <!-- 线程池所使用的缓冲队列 -->
<span style="white-space:pre"> </span><property name ="queueCapacity" value ="200" />
</bean>

ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
ThreadPoolTaskExecutor poolTaskExecutor = (ThreadPoolTaskExecutor)ctx.getBean("taskExecutor");

Thread udpThread = new Thread(udp);
poolTaskExecutor.execute(udpThread);
获取当前线程池活动的线程数：
int count = poolTaskExecutor.getActiveCount();
logger.debug("[x] - now threadpool active threads totalNum : " +count);