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 15dfb2cb01..532dfdd432 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 @@ void concurrentComputeBundleFileIfAbsent() {
 
             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 -> {