Cara menggunakan multi-threading dengan elegan dalam SpringBoot

Penggunaan pantas

Anotasi @EnableAsync perlu ditambahkan pada aplikasi SpringBoot untuk mendayakan panggilan tak segerak Secara umumnya, kumpulan benang akan dikonfigurasikan dan kaedah tak segerak akan dilengkapkan oleh kumpulan benang tertentu. seperti berikut:

@Configuration
@EnableAsync
public class AsyncConfiguration {
 
    @Bean("doSomethingExecutor")
    public Executor doSomethingExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心线程数：线程池创建时候初始化的线程数
        executor.setCorePoolSize(10);
        // 最大线程数：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程
        executor.setMaxPoolSize(20);
        // 缓冲队列：用来缓冲执行任务的队列
        executor.setQueueCapacity(500);
        // 允许线程的空闲时间60秒：当超过了核心线程之外的线程在空闲时间到达之后会被销毁
        executor.setKeepAliveSeconds(60);
        // 线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池
        executor.setThreadNamePrefix("do-something-");
        // 缓冲队列满了之后的拒绝策略：由调用线程处理（一般是主线程）
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
        executor.initialize();
        return executor;
    }
 
}

Kaedah penggunaannya sangat mudah, tambah anotasi @Async pada kaedah yang memerlukan asynchronous

@RestController
public class AsyncController {
 
    @Autowired
    private AsyncService asyncService;
 
    @GetMapping("/open/something")
    public String something() {
        int count = 10;
        for (int i = 0; i < count; i++) {
            asyncService.doSomething("index = " + i);
        }
        return "success";
    }
}
 
 
@Slf4j
@Service
public class AsyncService {
 
    // 指定使用beanname为doSomethingExecutor的线程池
    @Async("doSomethingExecutor")
    public String doSomething(String message) {
        log.info("do something, message={}", message);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            log.error("do something error: ", e);
        }
        return message;
    }
}

Akses: 127.0.0.1:8080/open/something, lognya seperti berikut

2023 -02-06 23:42:42.486 INFO 21168 --- [io-8200-exec-17] x.g.b.system.controller.AsyncController : lakukan sesuatu tamat, masa 8 milisaat
2023-02-06 23:42:42.488 INFO 21168 --- [ do-something-1] x.gits.boot.system.service.AsyncService : buat sesuatu, message=index = 0
2023-02 -06 23:42:42.488 INFO 21168 --- [ do-something-5] x.gits.boot.system.service.AsyncService : buat sesuatu, message=index = 4
2023-02-06 23:42 :42.488 INFO 21168 --- [ do-something- 4] x.gits.boot.system.service.AsyncService : buat sesuatu, message=index = 3
2023-02-06 23:42:42.488 INFO 21168 - -- [ do-something-6] x.gits .boot.system.service.AsyncService : buat sesuatu, message=index = 5
2023-02-06 23:42:42.488 INFO 21168 --- [ do- something-9] perkhidmatan x.gits.boot.system.AsyncService : lakukan sesuatu, message=index = 8
2023-02-06 23:42:42.488 INFO 21168 --- [ do-something-8] x .gits.boot.system.service.AsyncService : buat sesuatu, message=index = 7
2023-02-06 23:42:42.488 INFO 21168 --- [do-something-10] x.gits.boot. system.service.AsyncService : buat sesuatu, message=index = 9
2023-02-06 23:42:42.488 INFO 21168 --- [ do-something-7] x.gits.boot.system.service.AsyncService : buat sesuatu, message=index = 6
2023-02-06 23:42:42.488 INFO 21168 --- [ do-something-2] x.gits.boot.system.service.AsyncService : buat sesuatu, mesej =index = 1
2023-02-06 23:42:42.488 INFO 21168 --- [ do-something-3] x.gits.boot.system.service.AsyncService : buat sesuatu, message=index = 2

Ini menunjukkan bahawa ia mempunyai Kesan pelaksanaan tak segerak dicapai, dan kumpulan benang yang kami konfigurasikan digunakan.

Dapatkan nilai pulangan kaedah tak segerak

Apabila kaedah tak segerak mempunyai nilai pulangan, bagaimana untuk mendapatkan hasil pulangan pelaksanaan kaedah tak segerak? Pada masa ini, kaedah yang perlu dipanggil secara tak segerak mempunyai nilai pulangan CompletableFuture.

CompletableFuture ialah peningkatan kepada Ciri hanya boleh mengendalikan tugas tak segerak yang mudah, manakala CompletableFuture boleh melakukan gabungan kompleks berbilang tugas tak segerak. Seperti berikut:

@RestController
public class AsyncController {
 
    @Autowired
    private AsyncService asyncService;
 
    @SneakyThrows
    @ApiOperation("异步 有返回值")
    @GetMapping("/open/somethings")
    public String somethings() {
        CompletableFuture<String> createOrder = asyncService.doSomething1("create order");
        CompletableFuture<String> reduceAccount = asyncService.doSomething2("reduce account");
        CompletableFuture<String> saveLog = asyncService.doSomething3("save log");
 
        // 等待所有任务都执行完
        CompletableFuture.allOf(createOrder, reduceAccount, saveLog).join();
        // 获取每个任务的返回结果
        String result = createOrder.get() + reduceAccount.get() + saveLog.get();
        return result;
    }
}
 
 
@Slf4j
@Service
public class AsyncService {
 
    @Async("doSomethingExecutor")
    public CompletableFuture<String> doSomething1(String message) throws InterruptedException {
        log.info("do something1: {}", message);
        Thread.sleep(1000);
        return CompletableFuture.completedFuture("do something1: " + message);
    }
 
    @Async("doSomethingExecutor")
    public CompletableFuture<String> doSomething2(String message) throws InterruptedException {
        log.info("do something2: {}", message);
        Thread.sleep(1000);
        return CompletableFuture.completedFuture("; do something2: " + message);
    }
 
    @Async("doSomethingExecutor")
    public CompletableFuture<String> doSomething3(String message) throws InterruptedException {
        log.info("do something3: {}", message);
        Thread.sleep(1000);
        return CompletableFuture.completedFuture("; do something3: " + message);
    }
}

Akses antara muka

C:UsersAdministrator>curl -X GET "http://localhost:8080/open/something" -H "accept: */* "
buat sesuatu1: buat pesanan;
buat sesuatu2: kurangkan akaun;
buat sesuatu3: simpan log

Log kunci pada konsol adalah seperti berikut:

2023-02-06 00:27:42.238 INFO 5672 --- [ do-something-3] x.gits.boot.system.service.AsyncService : buat sesuatu3: save log
2023-02 -06 00: 27:42.238 INFO 5672 --- [ do-something-2] x.gits.boot.system.service.AsyncService : buat sesuatu2: kurangkan akaun
2023-02-06 00:27:42.238 INFO 5672 --- [ do-something-1] x.gits.boot.system.service.AsyncService : buat sesuatu1: buat pesanan

Nota

Anotasi @Async akan digunakan dalam senario berikut Tidak sah, iaitu anotasi @Async digunakan dengan jelas, tetapi berbilang benang tidak digunakan.

• Kaedah tak segerak diubah suai dengan kata kunci statik; @Service digunakan dan boleh diimbas oleh Spring);

• Anotasi @EnableAsync tidak ditambahkan pada aplikasi SpringBoot; kelas yang sama, panggilan kaedah Untuk kaedah lain dengan anotasi @Async, anotasi tidak akan berkuat kuasa. Sebabnya ialah kaedah yang dianotasi dengan @Async dilaksanakan dalam kelas proksi.

• Perlu diambil perhatian bahawa: nilai pulangan kaedah tak segerak menggunakan anotasi @Async hanya boleh terbatal atau Masa Depan dan subkelasnya Apabila hasil pulangan adalah jenis lain, kaedah itu masih akan dilaksanakan secara tak segerak , tetapi nilai pulangan semuanya batal, sebahagian daripada kod sumber adalah seperti berikut:

AsyncExecutionInterceptor#invoke

Melalui contoh di atas, @Async sebenarnya masih melepasi Future atau CompletableFuture Untuk pelaksanaan asynchronous, Spring telah merangkumnya untuk menjadikannya lebih mudah untuk kita gunakan.

Atas ialah kandungan terperinci Cara menggunakan multi-threading dengan elegan dalam SpringBoot. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!