如何在线程池中创建持状态可运行任务，复用非线程安全的DocumentBuilder

针对你需要复用固定数量（至少10个）非线程安全DocumentBuilder的场景，有两种高效的实现方式，完全满足你的需求：

方案一：使用ThreadLocal（推荐，无依赖） #

ThreadLocal天生就是为每个线程绑定独立实例设计的，配合固定大小的线程池，刚好能让每个线程持有一个DocumentBuilder实例，复用次数和线程一致，不会额外创建实例。

实现代码 #

1. 定义ThreadLocal初始化器：

private static final ThreadLocal<DocumentBuilder> DOC_BUILDER_THREAD_LOCAL = ThreadLocal.withInitial(() -> {
    try {
        return DocumentBuilderFactory.newInstance().newDocumentBuilder();
    } catch (ParserConfigurationException e) {
        throw new RuntimeException("创建DocumentBuilder失败", e);
    }
});

2. 编写可复用的任务类：

public class XmlProcessingTask implements Runnable {
    private final String xmlContent;

    public XmlProcessingTask(String xmlContent) {
        this.xmlContent = xmlContent;
    }

    @Override
    public void run() {
        DocumentBuilder builder = DOC_BUILDER_THREAD_LOCAL.get();
        try {
            // 核心业务：使用builder解析XML
            Document doc = builder.parse(new InputSource(new StringReader(xmlContent)));
            // 这里添加你的业务处理逻辑
        } catch (Exception e) {
            // 根据业务场景处理异常，比如日志记录、告警等
        } finally {
            // 必须重置状态，避免下一次使用时被之前的上下文污染
            builder.reset();
        }
    }
}

3. 配置固定大小的线程池：

// 核心线程数设为10，确保最多只创建10个DocumentBuilder实例
ExecutorService executor = Executors.newFixedThreadPool(10);
// 提交任务
executor.submit(new XmlProcessingTask("<xml>...</xml>"));

关键注意点 #

• 线程池必须用固定核心线程数的配置（比如newFixedThreadPool），避免线程动态销毁/创建导致实例数波动。
• 一定要在finally块中调用reset()，无论任务执行成功还是失败，都保证实例状态干净，供下一次复用。

方案二：使用对象池（灵活，需第三方依赖） #

如果需要更灵活的实例管理（比如动态调整实例数、跨线程池共享实例），可以用Apache Commons Pool2实现对象池，限制最大实例数为10，每次用完归还并重置。

实现代码 #

1. 引入Commons Pool2依赖（Maven为例）：

<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
    <version>2.12.0</version>
</dependency>

2. 创建对象池配置和工厂：

GenericObjectPoolConfig<DocumentBuilder> poolConfig = new GenericObjectPoolConfig<>();
poolConfig.setMaxTotal(10); // 最大实例数
poolConfig.setMinIdle(10);  // 保持10个空闲实例，避免频繁创建

ObjectPool<DocumentBuilder> docBuilderPool = new GenericObjectPool<>(new BasePooledObjectFactory<DocumentBuilder>() {
    @Override
    public DocumentBuilder create() throws Exception {
        return DocumentBuilderFactory.newInstance().newDocumentBuilder();
    }

    @Override
    public PooledObject<DocumentBuilder> wrap(DocumentBuilder obj) {
        return new DefaultPooledObject<>(obj);
    }

    @Override
    public void passivateObject(PooledObject<DocumentBuilder> p) throws Exception {
        // 归还实例时自动重置状态
        p.getObject().reset();
    }
});

3. 编写任务类：

public class XmlProcessingTask implements Runnable {
    private final String xmlContent;
    private final ObjectPool<DocumentBuilder> pool;

    public XmlProcessingTask(String xmlContent, ObjectPool<DocumentBuilder> pool) {
        this.xmlContent = xmlContent;
        this.pool = pool;
    }

    @Override
    public void run() {
        DocumentBuilder builder = null;
        try {
            builder = pool.borrowObject();
            // 解析XML并处理业务逻辑
            Document doc = builder.parse(new InputSource(new StringReader(xmlContent)));
        } catch (Exception e) {
            // 异常处理
        } finally {
            if (builder != null) {
                try {
                    pool.returnObject(builder);
                } catch (Exception e) {
                    // 处理归还失败的异常
                }
            }
        }
    }
}

方案对比 #

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