在Java EE容器中使用Java 8并行流是否被反对？

Question

鉴于在Java EE容器中生成线程是不被鼓励的，那么在Java EE内部使用可能会生成线程的Java 8并行流是否也不被鼓励呢？请参考此处和此处。

- Luís Bianchin

---

@RobertHarvey 在JavaEE中使用线程是不被鼓励的，Java 8引入了并行流（在后台使用线程）。我们能否在JavaEE中使用并行流，或者也被不鼓励？我认为这是一个公正而有趣的问题。我稍微改了一下措辞 - 可能还可以进一步改进。 - assylias

@RobertHarvey？线程被不少规格说明书所禁止或不鼓励，因为线程应该由应用服务器自行管理（请参考右侧的第一个链接）。使用并行流可能会“破坏”一些东西——也可能不会。这就是问题所在。根据规格说明书，它可能会或可能不会“破坏”某些东西：这不是一个观点。只是我的个人见解。你决定吧——我今天就到这儿！;-)（在做出决定后，请随意删除杂音） - assylias

是的，这会破坏一些东西。例如，安全和事务上下文是由ThreadLocal变量处理的。而且JPA实体不是线程安全的。因此，无论如何启动线程，都将破坏安全性和事务处理。Java EE 7规范引入了特殊执行器，如果您想在Java EE环境中执行线程任务，则应使用它们。但Java EE落后于Java SE，尚未准备好使用并行流。 - JB Nizet

这是一个很好的问题，已经被Java EE工程师回答了。他们将所有并行操作转换为顺序处理。您可以在[e-mail]邮件列表中找到讨论。 - edharned

@Shorn：http://mail.openjdk.java.net/pipermail/lambda-dev/2013-April/009334.html - JB Nizet

Answer 1

提醒一下，优雅降级到单线程不可用。我之前也认为是因为Shorn的回答和邮件列表讨论导致的，但在为这个问题进行研究时发现并非如此。该机制既不在Java EE 7规范中，也不在glassfish 4.1中。即使另一个容器能够实现它，它也不具备可移植性。

您可以通过调用以下方法进行测试：

@Singleton
public class SomeSingleton {
    public void fireStream() {
        IntStream.range(0, 32)
            .parallel()
            .mapToObj(i -> String.format("Task %d on thread %s", 
                i, Thread.currentThread().getName()))
            .forEach(System.out::println);
    }
}

然后你会得到类似这样的东西：

Info:   Task 20 on thread http-listener-1(4)
Info:   Task 10 on thread ForkJoinPool.commonPool-worker-3
Info:   Task 28 on thread ForkJoinPool.commonPool-worker-0
...

我还检查了Glassfish 4.1.1的源代码，并没有一个使用、或的地方。

这个机制可以添加到EE 8中，因为许多框架将利用jdk8的特性，但我不知道它是否是规范的一部分。

- andrepnh

---

通过将java.util.concurrent.ForkJoinPool.common.parallelism系统属性设置为1，可以以便携的方式实现优雅降级吗？ - areus

Answer 2

编辑 请查看andrepnh的备选答案。以下是计划，但在实践中似乎并未发生。

---

我从评论中提到的lambda-dev邮件列表讨论中看到的方式：它不像生成线程那样被强烈反对，但在Java EE环境中不会为您做太多事情。

来自链接讨论：

Java EE并发人员已经通过了这个问题，目前的结果是当从EE容器中运行时，FJP将优雅地降级为单线程（甚至调用者上下文）执行

因此，您可以安全地在同时运行于两种情况下的程序或库中使用并行流。当在SE环境中运行时，它将使用神奇的并行功能，但当在EE环境中运行时，它将优雅地降级为串行执行。

注意：上面引用的短语是将来时态 - 有没有一些明确的文档引用？

- Shorn

---

优雅降级并行流处理到单线程目前还不是Java EE Concurrency的一部分。因此，在Java EE 8中使用并行流仍然是不安全的。未来计划在Jakarta EE Concurrency中解决这个问题：https://github.com/eclipse-ee4j/concurrency-api/issues/46 - OndroMih