0

我正在使用 Vertx 和 Log4j2。

这是代码Remote.java

public class Remote extends AbstractVerticle {

    @Override
    public void start() throws Exception {
        System.setProperty("isThreadContextMapInheritable", "true");
        ThreadContext.put("1", "Company");
        ThreadContext.put("2", "Sector");
        ThreadContext.put("3", "Address");
        ArrayList<String> arrayList = new ArrayList<>();
        for (int i = 1; i < 4; i++) {
            arrayList.add(String.valueOf(i));
        }
        arrayList.parallelStream().forEach(s -> {
            System.out.println("Key " + s + " Value is " + ThreadContext.get(s) + " Name: " + Thread.currentThread().getName());
        });
        System.out.println("After parallelStream");
    }
}

这是我的代码StartVerticle.java

public class StartVerticle {

    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();
        vertx.deployVerticle(new Remote());
    }
}

当我运行上面的代码时，我的输出是

Key 2 Value is Sector Name: vert.x-eventloop-thread-0
Key 1 Value is null Name: ForkJoinPool.commonPool-worker-3
Key 3 Value is null Name: ForkJoinPool.commonPool-worker-5
After parallelStream

您能帮我获得以下输出吗？

Key 2 Value is Sector Name: vert.x-eventloop-thread-0
Key 1 Value is Company Name: ForkJoinPool.commonPool-worker-3
Key 3 Value is Address Name: ForkJoinPool.commonPool-worker-5
After parallelStream

我还打印了线程名称以供参考。在不使用 Vertx 的情况下，我可以ThreadContext在设置isThreadContextMapInheritable为true.

4

1 回答 1

1

Vertx并且Parallel Stream都使用 Fork Join Common Pool。只有在公共池初始化之前设置的线程上下文值在子线程中可用。

即使没有 Vertx，ThreadContext在第一个并行流之后设置的值也不会在子线程中可用。例如，

public static void main(String[] args) throws Exception {
    System.setProperty("isThreadContextMapInheritable", "true");
    IntStream.range(0, 5)
             .parallel()
             .forEach(System.out::println);
    ThreadContext.put("1", "Company");
    ThreadContext.put("2", "Sector");
    ThreadContext.put("3", "Address");

    ArrayList<String> arrayList = new ArrayList<>();
    for (int i = 1; i < 4; i++) {
        arrayList.add(String.valueOf(i));
    }
    arrayList.parallelStream()
             .forEach(s -> {
                 System.out.println("Key " + s + " Value is " + ThreadContext.get(s) + " Name: " + Thread.currentThread()
                                                                                                         .getName());
             });
}

这将打印

Key 1 Value is null Name: ForkJoinPool.commonPool-worker-5
Key 3 Value is null Name: ForkJoinPool.commonPool-worker-1
Key 2 Value is Sector Name: main

在我们的例子中，公共池在Vertx启动时被初始化。此时，没有设置线程上下文值。
所以一种选择是main()在启动 vertx 之前设置线程上下文。

public static void main(String[] args) {
    System.setProperty("isThreadContextMapInheritable", "true");
    ThreadContext.put("1", "Company");
    ThreadContext.put("2", "Sector");
    ThreadContext.put("3", "Address");
    Vertx vertx = Vertx.vertx();
    vertx.deployVerticle(new Remote());
}

产生输出，

Key 2 Value is Sector Name: vert.x-eventloop-thread-0
Key 3 Value is Address Name: ForkJoinPool.commonPool-worker-2
Key 1 Value is Company Name: ForkJoinPool.commonPool-worker-1
After parallelStream
于 2020-11-30T15:59:28.513 回答