有状态和无状态lambda表达式有什么区别？

Question

根据OCP的书，必须避免有状态操作，否则称为有状态lambda表达式。本书中提供的定义是“有状态的lambda表达式，其结果取决于在管道执行期间可能更改的任何状态”。

它们提供了一个示例，其中使用并行流使用.map()函数将固定的数字集合添加到同步的ArrayList 。

arraylist中的顺序是完全随机的，这应该使人看到有状态的lambda表达式在运行时会产生不可预测的结果。因此，强烈建议在使用并行流时避免有状态操作，以消除任何潜在的数据副作用。

它们没有显示提供相同问题的解决方案的无状态lambda表达式（将数字添加到同步数组列表），而且我仍然不明白使用map函数用数据填充空的同步数组列表会带来什么问题。
..管道执行期间可能会改变的确切状态是什么？他们是在指数组列表本身吗？就像当并行流仍在添加数字并因此改变最终结果的过程中另一个线程决定将其他数据添加到ArrayList时一样？

也许有人可以为我提供一个更好的示例，以说明有状态的lambda表达式是什么以及为什么应避免使用它。这将不胜感激。

谢谢

Answer 1

为了尝试举一个例子，让我们考虑以下内容Consumer（注意：这种功能的有用性在这里并不重要）：

public static class StatefulConsumer implements IntConsumer {

    private static final Integer ARBITRARY_THRESHOLD = 10;
    private boolean flag = false;
    private final List<Integer> list = new ArrayList<>();

    @Override
    public void accept(int value) {
        if(flag){   // exit condition
            return; 
        }
        if(value >= ARBITRARY_THRESHOLD){
            flag = true;
        }
        list.add(value); 
    }

}

它是一个将向其中添加项目的消费者List（让我们既不考虑如何获取列表又不考虑线程安全性），并具有一个标志（表示状态）。

其背后的逻辑是，一旦达到阈值，消费者应停止添加商品。

您的书试图说的是，因为没有确定的顺序，函数将必须使用的元素Stream，因此输出是不确定的。

因此，它们建议您仅使用无状态函数，这意味着它们将始终在相同的输入下产生相同的结果。