Selenium+Extent Reports并行执行报错：Close提前于endTest调用

我之前也遇到过一模一样的问题，TestNG并行执行方法时ExtentReports报ExtentTestInterruptedException，核心原因就是多线程下共享的static ExtentTest/ExtentReports实例导致的线程冲突，加上TestNG的AfterSuite在所有线程的AfterMethod执行完成前就触发了。下面给你一套亲测有效的解决方案：

问题根源拆解 #

1. 你原来的代码用了static修饰ExtentReports和ExtentTest，并行执行时所有线程共享同一个Test实例，会导致测试日志混乱，而且flush()和close()的时机完全不可控。
2. TestNG的AfterSuite是在测试套件的"逻辑完成"时触发，但并行执行时，部分线程的AfterMethod还在跑，AfterSuite就已经调用close()了，直接导致报错。

具体修改方案 #

第一步：重构ExtentReportService，用ThreadLocal实现线程隔离 #

把共享的static Test实例换成ThreadLocal，同时用单例模式确保ExtentReports全局唯一，再加CountDownLatch等待所有测试方法执行完毕：

import com.relevantcodes.extentreports.ExtentReports;
import com.relevantcodes.extentreports.ExtentTest;
import java.util.concurrent.CountDownLatch;
import java.lang.reflect.Method;

public class ExtentReportService implements ReportService {
    // 全局唯一的ExtentReports实例，双重检查锁实现线程安全的单例
    private static volatile ExtentReports extent;
    // 每个线程独立存储ExtentTest，避免多线程冲突
    private static final ThreadLocal<ExtentTest> testThreadLocal = new ThreadLocal<>();
    // 用于等待所有测试方法的AfterMethod执行完毕
    private CountDownLatch testCompleteLatch;

    // 初始化ExtentReports，确保全局唯一
    private ExtentReports getExtentInstance(Config config) {
        if (extent == null) {
            synchronized (ExtentReportService.class) {
                if (extent == null) {
                    extent = new ExtentReports(config.getReportPath(), true);
                    // 可添加系统信息，比如环境、浏览器等
                    extent.addSystemInfo("Environment", config.getEnvironment());
                }
            }
        }
        return extent;
    }

    // 初始化计数器，传入测试方法总数
    public void initTestLatch(int totalTestMethodCount) {
        this.testCompleteLatch = new CountDownLatch(totalTestMethodCount);
    }

    @Override
    public void startTest(Method method) {
        TestMetaData metaData = getTestMetaData(method);
        ExtentTest currentTest = getExtentInstance(getConfig())
                .startTest(metaData.getId(), metaData.getSummary());
        testThreadLocal.set(currentTest);
    }

    @Override
    public void endTest() {
        ExtentTest currentTest = testThreadLocal.get();
        if (currentTest != null) {
            extent.endTest(currentTest);
            extent.flush();
            testThreadLocal.remove(); // 清理线程本地存储，避免内存泄漏
        }
        // 每个测试方法执行完毕，计数器减一
        if (testCompleteLatch != null) {
            testCompleteLatch.countDown();
        }
    }

    @Override
    public void close() {
        try {
            // 等待所有线程的AfterMethod都执行完再关闭报告
            if (testCompleteLatch != null) {
                testCompleteLatch.await();
            }
            if (extent != null) {
                extent.flush();
                extent.close();
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            e.printStackTrace();
        }
    }

    // 这里实现你的getTestMetaData和getConfig方法
    private TestMetaData getTestMetaData(Method method) {
        // 返回你的测试元数据
        return new TestMetaData();
    }

    private Config getConfig() {
        // 返回你的配置实例
        return new Config();
    }
}

第二步：修改BaseTest，传递测试方法总数给计数器 #

在BeforeSuite里获取测试套件的总方法数，初始化CountDownLatch，确保AfterSuite能等待所有测试完成：

import org.testng.ITestContext;
import org.testng.annotations.BeforeSuite;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.AfterMethod;
import org.testng.annotations.AfterSuite;
import java.lang.reflect.Method;

public class BaseTest {
    private ReportService reportService;

    @BeforeSuite
    public void setupReport(ITestContext testContext) {
        Config config = getConfig();
        reportService = new ExtentReportService(config);
        // 获取测试套件中所有测试方法的总数
        int totalTests = testContext.getAllTestMethods().length;
        ((ExtentReportService) reportService).initTestLatch(totalTests);
    }

    @BeforeMethod
    public void startTest(Method method) {
        reportService.startTest(method);
    }

    @AfterMethod
    public void finishTest() {
        reportService.endTest();
    }

    @AfterSuite
    public void closeReport() {
        reportService.close();
    }

    private Config getConfig() {
        // 返回你的配置对象
        return new Config();
    }
}

关键注意点 #

1. 不要用static修饰ExtentTest：ThreadLocal会为每个线程创建独立的Test实例，彻底解决多线程日志混乱的问题。
2. CountDownLatch的作用：强制AfterSuite的close()等待所有AfterMethod的endTest()执行完毕，从根源避免"提前关闭"的报错。
3. 单例ExtentReports：确保整个测试套件只有一个报告实例，不会生成多个报告文件。

如果你的ExtentReports版本是5.x及以上，API会有些变化（比如ExtentReports的初始化方式、startTest改为createTest），但核心思路——线程隔离Test实例+等待所有测试完成再关闭报告——是完全通用的。

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