并行流在tomcat升级后不设置Thread.contextClassLoader

Question

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

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

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

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

ParallelStream在最新的Tomcat中使用ForkJoinPool。

Answer 1

公共ForkJoin池存在问题，可能导致内存泄漏和应用程序能够从其他上下文/应用程序加载类和资源(如果tomcat是多租户的话，则可能存在安全漏洞)。看这个Tomcat Bugzilla报告。

在Tomcat 8.5.11中，他们通过引入SafeForkJoinWorkerThreadFactory.java解决了上述问题

为了使代码工作，可以执行以下操作，这将为执行ForkJoin及其worker线程工厂提供显式的。

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

Answer 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())