2019-05-23 @Async并行

1.常规代码顺序执行

如下定义三个任务，然后在单元测试依次调用三个任务，可以看到执行结果是先后执行三个任务，必须等待前一个任务结束后才能开始下一个任务，总共耗时6000多毫秒
测试类

package com.ghw.async;

import javafx.scene.paint.Stop;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.AutoConfigureOrder;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.util.StopWatch;

@RunWith(SpringRunner.class)
@SpringBootTest
public class AsyncApplicationTests {

    @Autowired
    private Task task;

    private static StopWatch stopWatch = new StopWatch();

    @Test
    public void contextLoads() {
    }

    @Test
    public void test() throws Exception {
        task.setStopWatch(stopWatch);
        task.doTaskOne();
        task.doTaskTwo();
        task.doTaskThree();
        System.out.println(stopWatch.prettyPrint());
    }
}

Task类

package com.ghw.async;

import org.springframework.stereotype.Component;
import org.springframework.util.StopWatch;

import java.util.Random;
import java.util.concurrent.TimeUnit;

@Component
public class Task {

    private StopWatch stopWatch;

    public void setStopWatch(StopWatch stopWatch) {
        this.stopWatch = stopWatch;
    }

    public void doTaskOne() throws Exception {
        stopWatch.start("task1");
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
    }

    public void doTaskTwo() throws Exception {
        stopWatch.start("task2");
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
    }

    public void doTaskThree() throws Exception {
        stopWatch.start("task3");
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
    }
}

执行结果

StopWatch '': running time (millis) = 6039
-----------------------------------------
ms     %     Task name
-----------------------------------------
02014  033%  task1
02013  033%  task2
02012  033%  task3

2.采用@Async注解异步执行

Task类

package com.ghw.async;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.stereotype.Component;
import org.springframework.util.StopWatch;

import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

@Component
public class Task {

    @Async
    public Future<String> doTaskOne() throws Exception {
        StopWatch stopWatch = new StopWatch();
        String task = "task1";
        stopWatch.start(task);
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
        System.out.println(task + " spend time:" + stopWatch.getLastTaskTimeMillis());
        return new AsyncResult<>(task + " is finished");
    }

    @Async
    public Future<String> doTaskTwo() throws Exception {
        StopWatch stopWatch = new StopWatch();
        String task = "task2";
        stopWatch.start(task);
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
        System.out.println(task + " spend time:" + stopWatch.getLastTaskTimeMillis());
        return new AsyncResult<>(task + " is finished");
    }

    @Async
    public Future<String> doTaskThree() throws Exception {
        StopWatch stopWatch = new StopWatch();
        String task = "task3";
        stopWatch.start(task);
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
        System.out.println(task + " spend time:" + stopWatch.getLastTaskTimeMillis());
        return new AsyncResult<>(task + " is finished");
    }
}

测试类

package com.ghw.async;

import javafx.scene.paint.Stop;
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;
import org.springframework.util.StopWatch;

import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

@RunWith(SpringRunner.class)
@SpringBootTest
public class AsyncApplicationTests {

    @Autowired
    private Task task;

    private static StopWatch stopWatch = new StopWatch();

    @Test
    public void contextLoads() {
    }

    @Test
    public void test() throws Exception {
        StopWatch stopWatch = new StopWatch();
        stopWatch.start("all");
        Future<String> task1 = task.doTaskOne();
        Future<String> task2 = task.doTaskTwo();
        Future<String> task3 = task.doTaskThree();

        while (true) {
            if (task1.isDone() && task2.isDone() && task3.isDone()) {
                // 三个任务都调用完成，退出循环等待
                break;
            }
        }
        stopWatch.stop();
        System.out.println("all task spend time:" + stopWatch.getLastTaskTimeMillis());
    }
}

执行结果

task3 spend time:2014
task1 spend time:2014
task2 spend time:2014
all task spend time:2060

可以看出只需要2060毫秒，三个任务就全部执行完成了，相比第一种方法，能够提高3倍速度。
其中使用Future<T>来返回异步调用的结果。在while循环中判断，当三个任务全部完成的时候，退出while循环。

采用自己配置的线程池

package com.ghw.async;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.util.StopWatch;

import java.util.concurrent.TimeUnit;

@Slf4j
@Component
public class Task {

    @Async(value = "taskExecutor")
    public void doTaskOne() throws Exception {
        log.info("开始做任务一");
        StopWatch stopWatch = new StopWatch();
        String task = "task1";
        stopWatch.start(task);
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
        log.info("完成任务一，耗时：" + (stopWatch.getLastTaskTimeMillis()) + "毫秒");
    }

    @Async(value = "taskExecutor")
    public void doTaskTwo() throws Exception {
        log.info("开始做任务二");
        StopWatch stopWatch = new StopWatch();
        String task = "task2";
        stopWatch.start(task);
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
        log.info("完成任务二，耗时：" + (stopWatch.getLastTaskTimeMillis()) + "毫秒");
    }

    @Async(value = "taskExecutor")
    public void doTaskThree() throws Exception {
        log.info("开始做任务三");
        StopWatch stopWatch = new StopWatch();
        String task = "task3";
        stopWatch.start(task);
        TimeUnit.SECONDS.sleep(2);
        stopWatch.stop();
        log.info("完成任务三，耗时：" + (stopWatch.getLastTaskTimeMillis()) + "毫秒");
    }
}

package com.ghw.async;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;

@SpringBootApplication
public class AsyncApplication {

    public static void main(String[] args) {
        SpringApplication.run(AsyncApplication.class, args);
    }

    @EnableAsync
    @Configuration
    class TaskPoolConfig {

        @Bean("taskExecutor")
        public Executor taskExecutor() {
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            executor.setCorePoolSize(10);
            executor.setMaxPoolSize(20);
            executor.setQueueCapacity(200);
            executor.setKeepAliveSeconds(60);
            executor.setThreadNamePrefix("taskExecutor-");
            executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
            return executor;
        }
    }
}

单元测试

package com.ghw.async;

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.concurrent.ThreadPoolTaskExecutor;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.util.StopWatch;

@RunWith(SpringRunner.class)
@SpringBootTest
public class AsyncApplicationTests {

    @Autowired
    private Task task;

    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;

    private static StopWatch stopWatch = new StopWatch();

    @Test
    public void contextLoads() {
    }

    @Test
    public void test() throws Exception {
        task.doTaskOne();
        task.doTaskTwo();
        task.doTaskThree();
        Thread.currentThread().join();
    }
}

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,271评论 5赞 476
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,275评论 2赞 380
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,151评论 0赞 336
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,550评论 1赞 273
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,553评论 5赞 365
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,559评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,924评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,580评论 0赞 257
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,826评论 1赞 297
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,578评论 2赞 320
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,661评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,363评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,940评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,926评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,156评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,872评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,391评论 2赞 342

2019-05-23 @Async并行

1.常规代码顺序执行

2.采用@Async注解异步执行

推荐阅读更多精彩内容