替换Cucumber默认同步事件总线的可行方案咨询

针对你在Cucumber 7.13.0 + TestNG + Java 11环境下遇到的默认同步事件总线拖慢执行效率的问题，以下是可行的解决方案：

一、完全替换默认同步事件总线 #

Cucumber 7.x允许自定义事件总线实现，你可以通过实现io.cucumber.core.eventbus.EventBus接口替换默认的同步版本，核心思路是用异步逻辑处理事件分发，避免阻塞测试主线程。

实现步骤： #

1. 编写自定义异步事件总线
   基于线程池实现异步事件分发，同时保证线程安全（适配TestNG并行执行场景）：

   import io.cucumber.core.event.Event;
   import io.cucumber.core.event.EventListener;
   import io.cucumber.core.eventbus.EventBus;
   import java.util.Collections;
   import java.util.List;
   import java.util.Map;
   import java.util.concurrent.*;
   
   public class AsyncEventBus implements EventBus {
       // 根据CPU核心数调整线程池大小
       private final ExecutorService executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
       private final Map<Class<? extends Event>, List<EventListener<? super Event>>> listeners = new ConcurrentHashMap<>();
   
       @Override
       public <T extends Event> void register(Class<T> eventType, EventListener<? super T> listener) {
           listeners.computeIfAbsent(eventType, k -> new CopyOnWriteArrayList<>())
                   .add((EventListener<? super Event>) listener);
       }
   
       @Override
       public void send(Event event) {
           executor.submit(() -> {
               List<EventListener<? super Event>> eventListeners = listeners.getOrDefault(event.getClass(), Collections.emptyList());
               for (EventListener<? super Event> listener : eventListeners) {
                   listener.accept(event);
               }
           });
       }
   
       @Override
       public void close() {
           executor.shutdown();
           try {
               if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
                   executor.shutdownNow();
               }
           } catch (InterruptedException e) {
               executor.shutdownNow();
           }
       }
   }
   

2. 注册自定义事件总线
   通过继承AbstractTestNGCucumberTests，重写createRuntimeOptions方法注入自定义总线：

   import io.cucumber.core.runtime.RuntimeOptions;
   import io.cucumber.core.runtime.RuntimeOptionsBuilder;
   import io.cucumber.testng.AbstractTestNGCucumberTests;
   import io.cucumber.testng.CucumberOptions;
   
   @CucumberOptions(
           features = "src/test/resources/features",
           glue = "com.your.package.steps",
           plugin = {"pretty"}
   )
   public class CustomCucumberTest extends AbstractTestNGCucumberTests {
   
       @Override
       protected RuntimeOptions createRuntimeOptions() {
           RuntimeOptionsBuilder builder = new RuntimeOptionsBuilder();
           // 绑定自定义事件总线
           builder.setEventBusSupplier(AsyncEventBus::new);
           return builder.build();
       }
   }
   

二、无需替换总线的事件传播优化方案 #

如果不想完全重写事件总线，也可以通过以下方式优化事件处理效率：

1. 监听器内部异步处理 #

在自定义事件监听器中，将耗时逻辑（比如报告生成、日志写入）提交到线程池，避免阻塞事件分发线程：

import io.cucumber.core.event.TestRunFinished;
import io.cucumber.core.event.EventListener;
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;

public class AsyncTestReporter implements EventListener<TestRunFinished> {
    private final ExecutorService reportExecutor = Executors.newSingleThreadExecutor();

    @Override
    public void accept(TestRunFinished event) {
        reportExecutor.submit(() -> {
            // 耗时的报告生成逻辑
            generateDetailedReport(event.getResult());
        });
    }

    private void generateDetailedReport(io.cucumber.core.event.Result result) {
        // 实现报告生成逻辑
    }
}

2. 精简事件监听器/插件 #

检查CucumberOptions中配置的插件，移除不需要的报告器（比如同时启用多个格式的报告可能会增加事件处理负担），只保留必要的插件。

3. 线程安全优化（针对并行测试） #

如果开启TestNG并行执行，确保默认事件总线的监听器是线程安全的，避免同步块导致的阻塞。对于自定义监听器，优先使用线程安全的数据结构。

内容的提问来源于stack exchange，提问作者soumyadeep sarkar