I want to propagate TraceId to all places where parallelStream() and CustomForkJoinPool is used. about spring-cloud-sleuth HOT 3 CLOSED

    @Bean(name = "peterPool")
    @Lazy
    public Executor getCustomForkJoinPool(Tracer tracer) {
        final ForkJoinPool.ForkJoinWorkerThreadFactory factory = pool -> {
            final ForkJoinWorkerThread worker = ForkJoinPool.defaultForkJoinWorkerThreadFactory.newThread(pool);
            worker.setName("peterPool" + worker.getPoolIndex());
            return worker;
        };

        return new LazyTraceExecutor(beanFactory,
                new ForkJoinPool(Runtime.getRuntime().availableProcessors(), factory, null, true));
    }

    private final Executor peterPool;

    @GetMapping("/test")
    public String test() throws ExecutionException, InterruptedException {
        peterPool.execute(() -> {
            IntStream.range(1, 20).parallel().map(idx -> {
                httpClient.get(1000L);
                return idx;
            }).sum();
        });

        return "test";
    }