详解Springboot对多线程的支持

package com.spartajet.springbootlearn.thread;

import org.springframework.aop.interceptor.asyncuncaughtexceptionhandler;

import org.springframework.context.annotation.configuration;

import org.springframework.scheduling.annotation.asyncconfigurer;

import org.springframework.scheduling.annotation.enableasync;

import org.springframework.scheduling.concurrent.threadpooltaskexecutor;

import java.util.concurrent.executor;

/**

  * @description

  * @create 2017-02-22 下午11:53

  * @email gxz04220427@163.com

  */

@configuration

@enableasync

public class threadconfig implements asyncconfigurer {

   /**

    * the {@link executor} instance to be used when processing async

    * method invocations.

    */

   @override

   public executor getasyncexecutor() {

     threadpooltaskexecutor executor = new threadpooltaskexecutor();

     executor.setcorepoolsize( 5 );

     executor.setmaxpoolsize( 15 );

     executor.setqueuecapacity( 25 );

     executor.initialize();

     return executor;

   }

   /**

    * the {@link asyncuncaughtexceptionhandler} instance to be used

    * when an exception is thrown during an asynchronous method execution

    * with {@code void} return type.

    */

   @override

   public asyncuncaughtexceptionhandler getasyncuncaughtexceptionhandler() {

     return null ;

   }

}

package com.spartajet.springbootlearn.thread;

import org.springframework.scheduling.annotation.async;

import org.springframework.stereotype.service;

/**

  * @description

  * @create 2017-02-23 上午12:00

  * @email gxz04220427@163.com

  */

@service

public class asynctaskservice {

   @async

   public void executeasynctask( int i) {

     system.out.println( "线程" + thread.currentthread().getname() + " 执行异步任务：" + i);

   }

}

package com.spartajet.springbootlearn;

import com.spartajet.springbootlearn.thread.asynctaskservice;

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.test.context.junit4.springrunner;

@runwith (springrunner. class )

@springboottest

public class springbootlearnapplicationtests {

   @autowired

   private asynctaskservice asynctaskservice;

   @test

   public void contextloads() {

   }

   @test

   public void threadtest() {

     for ( int i = 0 ; i < 20 ; i++) {

       asynctaskservice.executeasynctask(i);

     }

   }

}