springboot多线程使用

生活中,最使人疲惫的往往不是道路的遥远,而是心中的郁闷;最使人痛苦的往往不是生活的不幸,而是希望的破灭;最使人颓废的往往不是前途的坎坷,而是自信的丧失;最使人绝望的往往不是挫折的打击,而是心灵的死亡。所以我们要有自己的梦想,让梦想的星光指引着我们走出落漠,走出惆怅,带着我们走进自己的理想。

导读:本篇文章讲解 springboot多线程使用,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com,来源:原文

package com.green.testlocalhost.controller;

import com.green.testlocalhost.vo.ResultData;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.CompletableFuture;

/**
 * @Author zdj
 * @Date 2022/10/28 17:11
 * @Version 1.0
 */
@Api(tags = "数据处理")
@RestController
@RequestMapping("/dataDetal")
public class DataController {

    /**
     *  spring自带的线程池对象
     **/
    @Autowired
    private ThreadPoolTaskExecutor applicationTaskExecutor;

    /**
     * 多线程处理1000万条数据
     * 开启两个线程处理这1000万条数据
     * @return
     */
    @RequestMapping(value = "/detalData", method = RequestMethod.GET)
    @ApiOperation(value = "多线程处理1000万条数据", notes = "多线程处理1000万条数据", httpMethod = "GET")
    public ResultData detalData(){
        CompletableFuture<Void> completableFuture1 = CompletableFuture.runAsync(() -> {
            for (int i = 0; i < 100000; i++) {
                System.out.println("a-" + i);
            }
        }, applicationTaskExecutor);

        CompletableFuture<Void> completableFuture2 = CompletableFuture.runAsync(() -> {
            for (int i = 0; i < 100000; i++) {
                System.out.println("w-" + i);
            }
        }, applicationTaskExecutor);

        // 等待这两个线程都执行完
        CompletableFuture.allOf(completableFuture1, completableFuture2).get();
        return ResultData.ok("处理完成!", null);
    }
}

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由半码博客整理,本文链接:https://www.bmabk.com/index.php/post/137443.html

(0)

相关推荐

发表回复

登录后才能评论
半码博客——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!