1.添加配置类

package com.yiyoudao.config;

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.ComponentScan;
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;


@Configuration
@EnableAsync
@ComponentScan(basePackages = {"com.yiyoudao"})
public class SpringThreadConfig implements AsyncConfigurer{

    @Override
    public Executor getAsyncExecutor() {

        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(15);
        taskExecutor.setMaxPoolSize(15);
        taskExecutor.setQueueCapacity(50);
        taskExecutor.initialize();
        return taskExecutor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

2.需要进行异步的方法，只需要在方法前添加@Async注解，调用这个方法的时候这个方法就会进行异步的执行。

package com.yiyoudao.service;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class SpringThread {

    private static int i = 0;

    @Async
    public void thread01(){
        while (i<100){

            System.out.println(Thread.currentThread().getName()+":"+i++);
        }
    }

    @Async
    public  void thread02(){
        while (i<100){

            System.out.println(Thread.currentThread().getName()+":"+i++);
        }
    }
}