摘要：對(duì)多線(xiàn)程的支持詳解這兩天看阿里的開(kāi)發(fā)手冊(cè)，到多線(xiàn)程的時(shí)候說(shuō)永遠(yuǎn)不要用這種方式來(lái)使用多線(xiàn)程。在使用線(xiàn)程池的大多數(shù)情況下都是異步非阻塞的。二配置類(lèi)配置類(lèi)代碼如下下午解讀利用來(lái)開(kāi)啟對(duì)于異步任務(wù)的支持配置類(lèi)實(shí)現(xiàn)接口，返回一個(gè)線(xiàn)程池對(duì)象。

這兩天看阿里的JAVA開(kāi)發(fā)手冊(cè)，到多線(xiàn)程的時(shí)候說(shuō)永遠(yuǎn)不要用 new Thread()這種方式來(lái)使用多線(xiàn)程。確實(shí)是這樣的，我一直在用線(xiàn)程池，到了springboot才發(fā)現(xiàn)他已經(jīng)給我們提供了很方便的線(xiàn)程池機(jī)制。
本博客代碼托管在github上https://github.com/gxz0422042...

Spring是通過(guò)任務(wù)執(zhí)行器(TaskExecutor)來(lái)實(shí)現(xiàn)多線(xiàn)程和并發(fā)編程，使用ThreadPoolTaskExecutor來(lái)創(chuàng)建一個(gè)基于線(xiàn)城池的TaskExecutor。在使用線(xiàn)程池的大多數(shù)情況下都是異步非阻塞的。我們配置注解@EnableAsync可以開(kāi)啟異步任務(wù)。然后在實(shí)際執(zhí)行的方法上配置注解@Async上聲明是異步任務(wù)。

配置類(lèi)代碼如下：

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;
    }
}

解讀：

利用EnableAsync來(lái)開(kāi)啟Springboot對(duì)于異步任務(wù)的支持

配置類(lèi)實(shí)現(xiàn)接口AsyncConfigurator，返回一個(gè)ThreadPoolTaskExecutor線(xiàn)程池對(duì)象。

任務(wù)執(zhí)行代碼：

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("線(xiàn)程" + Thread.currentThread().getName() + " 執(zhí)行異步任務(wù)：" + i);
    }
}

代碼解讀：

通過(guò)@Async注解表明該方法是異步方法，如果注解在類(lèi)上，那表明這個(gè)類(lè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);
        }
    }

}

測(cè)試結(jié)果：

線(xiàn)程ThreadPoolTaskExecutor-4 執(zhí)行異步任務(wù)：3
線(xiàn)程ThreadPoolTaskExecutor-2 執(zhí)行異步任務(wù)：1
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：0
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：7
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：8
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：9
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：10
線(xiàn)程ThreadPoolTaskExecutor-5 執(zhí)行異步任務(wù)：4
線(xiàn)程ThreadPoolTaskExecutor-3 執(zhí)行異步任務(wù)：2
線(xiàn)程ThreadPoolTaskExecutor-5 執(zhí)行異步任務(wù)：12
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：11
線(xiàn)程ThreadPoolTaskExecutor-2 執(zhí)行異步任務(wù)：6
線(xiàn)程ThreadPoolTaskExecutor-4 執(zhí)行異步任務(wù)：5
線(xiàn)程ThreadPoolTaskExecutor-2 執(zhí)行異步任務(wù)：16
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：15
線(xiàn)程ThreadPoolTaskExecutor-5 執(zhí)行異步任務(wù)：14
線(xiàn)程ThreadPoolTaskExecutor-3 執(zhí)行異步任務(wù)：13
線(xiàn)程ThreadPoolTaskExecutor-1 執(zhí)行異步任務(wù)：19
線(xiàn)程ThreadPoolTaskExecutor-2 執(zhí)行異步任務(wù)：18
線(xiàn)程ThreadPoolTaskExecutor-4 執(zhí)行異步任務(wù)：17