From 0bd8611144b1ef698c7b30f7bf0f2252645bd18a Mon Sep 17 00:00:00 2001
From: Halo Dev Bot <87291978+halo-dev-bot@users.noreply.github.com>
Date: Thu, 6 Jun 2024 14:28:14 +0800
Subject: [PATCH] [release-2.16] Fix concurrent issue during bundle file
 concurrent generation testing (#6045)

This is an automated cherry-pick of #6043

/assign JohnNiang

```release-note
None
```
---
 .../service/impl/PluginServiceImplTest.java       | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/application/src/test/java/run/halo/app/core/extension/service/impl/PluginServiceImplTest.java b/application/src/test/java/run/halo/app/core/extension/service/impl/PluginServiceImplTest.java
index 15dfb2cb0..532dfdd43 100644
--- a/application/src/test/java/run/halo/app/core/extension/service/impl/PluginServiceImplTest.java
+++ b/application/src/test/java/run/halo/app/core/extension/service/impl/PluginServiceImplTest.java
@@ -432,17 +432,20 @@ class PluginServiceImplTest {
 
             var probes = new ArrayList<PublisherProbe<DataBuffer>>();
             List<? extends Future<?>> futures = IntStream.range(0, 10)
-                .mapToObj(i -> executorService.submit(() -> {
+                .mapToObj(i -> {
                     var fakeContent = Mono.<DataBuffer>just(sharedInstance.wrap(
                         ("fake-content-" + i).getBytes(UTF_8)
                     ));
                     var probe = PublisherProbe.of(fakeContent);
                     probes.add(probe);
-                    cache.computeIfAbsent("fake-version", probe.mono())
-                        .as(StepVerifier::create)
-                        .expectNextCount(1)
-                        .verifyComplete();
-                }))
+                    return executorService.submit(
+                        () -> {
+                            cache.computeIfAbsent("fake-version", probe.mono())
+                                .as(StepVerifier::create)
+                                .expectNextCount(1)
+                                .verifyComplete();
+                        });
+                })
                 .toList();
             executorService.shutdown();
             futures.forEach(future -> {