如何并行执行两个Cucumber测试步骤？

由于Cucumber的步骤默认是串行执行的，要实现两个独立步骤的并行检查，可以通过以下几种方案实现：

1. 多线程封装步骤逻辑 #

将两个步骤的检查逻辑提取出来，放到独立线程中启动执行，等待所有线程完成后统一验证结果。这种方式不依赖第三方库，直接利用语言本身的多线程能力。

以Java为例：

@Then("同时检查车辆行驶状态和车门关闭状态")
public void parallelVehicleAndDoorCheck() throws InterruptedException {
    // 封装原"检查车辆是否在行驶"的逻辑
    Runnable vehicleCheck = () -> {
        assertTrue(vehicle.isMoving());
    };
    
    // 封装原"检查车门是否关闭"的逻辑
    Runnable doorCheck = () -> {
        assertTrue(door.isClosed());
    };
    
    // 启动并行线程
    Thread vehicleThread = new Thread(vehicleCheck);
    Thread doorThread = new Thread(doorCheck);
    
    vehicleThread.start();
    doorThread.start();
    
    // 等待两个线程执行完成
    vehicleThread.join();
    doorThread.join();
}

2. 用线程池管理并行任务 #

如果需要更高效的线程管理（比如复用线程），可以用线程池来执行两个检查任务，通过Future获取执行结果：

@Then("并行执行车辆与车门状态检查")
public void executeParallelChecks() throws ExecutionException, InterruptedException {
    ExecutorService executor = Executors.newFixedThreadPool(2);
    
    // 提交两个检查任务
    Future<Boolean> vehicleFuture = executor.submit(() -> vehicle.isMoving());
    Future<Boolean> doorFuture = executor.submit(() -> door.isClosed());
    
    // 验证结果
    assertTrue(vehicleFuture.get());
    assertTrue(doorFuture.get());
    
    executor.shutdown();
}

3. 保留原步骤复用性的并行封装 #

如果需要保留原两个步骤的独立使用能力，可以将原步骤的逻辑抽成独立方法，在并行步骤中调用这些方法并通过线程执行：

// 原独立步骤1：可单独调用
@Then("检查车辆是否在行驶")
public void checkVehicleIsMoving() {
    assertTrue(vehicle.isMoving());
}

// 原独立步骤2：可单独调用
@Then("检查车门是否关闭")
public void checkDoorIsClosed() {
    assertTrue(door.isClosed());
}

// 并行执行的复合步骤
@Then("同时检查车辆行驶和车门关闭")
public void runParallelChecks() throws InterruptedException {
    List<Exception> errors = Collections.synchronizedList(new ArrayList<>());
    
    Thread t1 = new Thread(() -> {
        try {
            checkVehicleIsMoving();
        } catch (Exception e) {
            errors.add(e);
        }
    });
    
    Thread t2 = new Thread(() -> {
        try {
            checkDoorIsClosed();
        } catch (Exception e) {
            errors.add(e);
        }
    });
    
    t1.start();
    t2.start();
    
    t1.join();
    t2.join();
    
    // 统一抛出检查中出现的异常
    if (!errors.isEmpty()) {
        throw new AssertionError("并行检查失败", errors.get(0));
    }
}

注意事项 #

• 若检查逻辑涉及共享资源，需处理线程安全问题，比如使用同步块或线程安全的数据结构。
• 要确保所有线程的异常都被捕获并汇总，避免单个线程失败但未被检测到的情况。

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