Tomcat升级后并行流不设置Thread.contextClassLoader答案

【问题标题】：Parallel stream doesn't set Thread.contextClassLoader after tomcat upgradeTomcat升级后并行流不设置Thread.contextClassLoader
【发布时间】：2018-08-13 02:42:27
【问题描述】：

在 tomcat 从 8.5.6 升级到 8.5.28 并行流后停止为线程提供 contextClassLoader：

因此Warmer::run 无法在其中加载类。

warmers.parallelStream().forEach(Warmer::run);

您知道 Tomcat 为新线程的 contextClassLoaders 提供了什么吗？

ParallelStream 在最新的 Tomcat 中使用 ForkJoinPool。

【问题讨论】：

Warmer::run无法加载类的症状是什么？
Thread.currentThread().getContextClassLoader() 返回 null @diginoise

标签： java java-stream tomcat8 forkjoinpool contextclassloader

【解决方案1】：

Common ForkJoin pool 存在问题，可能会导致内存泄漏以及应用程序能够从其他上下文/应用程序加载类和资源（如果您的 tomcat 是多租户，则可能存在安全漏洞）。看到这个Tomcat Bugzilla Report。

在Tomcat 8.5.11 中，他们通过引入SafeForkJoinWorkerThreadFactory.java 对上述问题进行了修复

为了让您的代码正常工作，您可以执行以下操作，这将为 Stream.parallel() 执行提供显式 ForkJoin 及其 worker thread factory。 p>

ForkJoinPool forkJoinPool = new ForkJoinPool(NO_OF_WORKERS);
forkJoinPool.execute(() -> warmers.parallelStream().forEach(Warmer::run));

【讨论】：

太棒了！这使我们解决了我们在使用 Apache Abdera 和 JDK10 时遇到的一个非常难以调试的问题。

【解决方案2】：

这拯救了我的一天！我必须这样做才能使其工作：

private static class CustomForkJoinWorkerThread extends ForkJoinWorkerThread {
    CustomForkJoinWorkerThread(ForkJoinPool pool) {
        super(pool);
        setContextClassLoader(Thread.currentThread().getContextClassLoader());
    }
}

private ForkJoinPool createForkJoinPool() {
    return new ForkJoinPool(
            ForkJoinPool.getCommonPoolParallelism(),
            CustomForkJoinWorkerThread::new,
            null,
            false
    );
}


createForkJoinPool().submit(() -> stuff.parallelStream().doStuff())

【讨论】：