如何为parallelStream设置ThreadLocal

Question

我有一个线程，其中包含ThreadLocal变量。我需要在上述线程内使用parallelStream()。需要调用使用线程本地变量的myService。在Java8中，在使用parallelstream()时是否有设置ThreadLocal的机制。

List<MyObject> result = myList.parallelStream().map(myObject -> {
    //call myService with the Threadlocal 
}).filter(...)
.....;

- Akila

---

请查看此链接：https://dev59.com/VFsX5IYBdhLWcg3wW-U7，希望它能解答你的问题。 - Amir

请查看此链接（https://dev59.com/VFsX5IYBdhLWcg3wW-U7）以获取您的问题，希望能有所帮助。 - Amir

如果myService依赖于线程本地变量，那么它很可能还没有准备好被多个线程调用。 - Holger

Answer 1

你可以在调用服务之前轻松设置线程本地变量。在映射中，您可以从主线程本地值或任何其他值设置值。

 ThreadLocal<String> threadLocal= new ThreadLocal<>();

        IntStream.range(0, 8).parallel().forEach(n -> {
            threadLocal.set("MAIN");
            System.out.println("This is sequence access "+n);
            System.out.printf("Service used ThreadLocal - %d: %s\n", n, threadLocal.get());
        });

结果：

This is sequence access 5
This is sequence access 7
Parallel Consumer - 5: MAIN
Parallel Consumer - 7: MAIN
This is sequence access 4
This is sequence access 6
Parallel Consumer - 4: MAIN
Parallel Consumer - 6: MAIN
This is sequence access 2
This is sequence access 1
Parallel Consumer - 2: MAIN
This is sequence access 0
This is sequence access 3
Parallel Consumer - 0: MAIN
Parallel Consumer - 1: MAIN
Parallel Consumer - 3: MAIN

- Paraneetharan Saravanaperumal

---

这不是一个有用的回答。虽然在这个简单的例子中，所有的代码都在同一个地方，那种技术可以起作用；但在实际情况下，你会使用ThreadLocal来在调用栈底部设置一些上下文，这样你就不必将该上下文作为参数从方法传递到方法再到方法，直到最终到达并行流执行的地方。其中一些介入的方法可能位于您甚至不能控制和修改的代码中。 - Doradus