多线程Kotlin测试中AllureLifecycle报错问题排查

Allure的测试上下文（包括测试用例、步骤的生命周期）是通过ThreadLocal管理的，默认仅绑定在执行@Test方法的主线程上。而parallelStream()使用的是ForkJoinPool中的独立线程，这些线程没有继承主线程的Allure上下文，因此在子线程中调用标注@Step的方法时，Allure无法找到对应的测试用例和步骤上下文，就会抛出日志中的错误。

单线程模式下所有操作都在主线程执行，Allure上下文持续有效，所以不会出现问题。

1. 手动传递Allure上下文到子线程 #

在主线程先获取当前的Allure生命周期，然后在每个并行任务中临时绑定上下文，执行完成后清理：

val mainLifecycle = Allure.getLifecycle()
(0..usersCount)
    .toList()
    .parallelStream()
    .forEach {
        // 将主线程的Allure上下文绑定到当前子线程
        Allure.lifecycle.set(mainLifecycle)
        try {
            userManager.insertAll(profileId)
        } finally {
            // 清理当前线程的上下文，避免干扰后续任务
            Allure.lifecycle.remove()
        }
    }

2. 手动管理步骤生命周期（不依赖@Step注解） #

绕开注解的自动代理逻辑，直接调用Allure API手动创建、更新和结束步骤：

import java.util.UUID
import io.qameta.allure.model.Status

(0..usersCount)
    .toList()
    .parallelStream()
    .forEach {
        val lifecycle = Allure.getLifecycle()
        // 手动启动步骤
        val stepId = lifecycle.startStep(UUID.randomUUID(), StepResult().apply {
            name = "Insert record"
        })
        try {
            userDAO.insertAll(profileId)
        } catch (e: Exception) {
            // 标记步骤执行失败
            lifecycle.updateStep(stepId) { it.status = Status.FAILED }
            throw e
        } finally {
            // 手动结束步骤
            lifecycle.stopStep(stepId)
        }
    }

3. 将并行操作封装为单个Step #

如果不需要为每条插入记录生成独立的Step，可以把整个并行插入操作作为一个大的Step，子线程中直接调用DAO方法（跳过带@Step的userManager方法）：

@Step("Batch insert {usersCount} records in parallel")
fun batchInsertParallel(profileId: String, usersCount: Int) {
    (0..usersCount)
        .toList()
        .parallelStream()
        .forEach {
            userDAO.insertAll(profileId)
        }
}

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