The springboot-otel-micrometer-jaeger from amithkumarg

springboot-otel-micrometer-jaeger's People

Stargazers

Watchers

springboot-otel-micrometer-jaeger's Issues

Can you add an example for a ForkJoinPool?

Can you add an example for a ForkJoinPool? What you have so far is tremendously helpful - it's more info than I've found anywhere else on the web including the Micrometer /Spring Boot 3.1 migration guide. I've yet to find an example for a ForkJoinPool.

My initial attempt looks something like this (using io.micrometer:context-propagation:1.0.3 ):

public class MicrometerWrappedForkJoinWorkerThreadFactory implements ForkJoinWorkerThreadFactory {

  @Override
  public ForkJoinWorkerThread newThread(final ForkJoinPool pool) {
    final ContextRegistry registry = ContextRegistry.getInstance();
    // Register thread local accessors (you can use SPI too)
    registry.registerThreadLocalAccessor(new ObservationThreadLocalAccessor());

    // When you set a thread local value...
    // ObservationThreadLocalHolder.setValue("hello");
    // ... we can capture it using ContextSnapshot
    final ContextSnapshot snapshot =
        ContextSnapshotFactory.builder().contextRegistry(registry).build().captureAll();

    final MicrometerWrappedForkJoinWorkerThread micrometerWrappedForkJoinWorkerThread =
        new MicrometerWrappedForkJoinWorkerThread(pool);

    snapshot.wrap(micrometerWrappedForkJoinWorkerThread);
    return micrometerWrappedForkJoinWorkerThread;
  }

  public class MicrometerWrappedForkJoinWorkerThread extends ForkJoinWorkerThread {
    /**
     * Creates a ForkJoinWorkerThread operating in the given pool.
     *
     * @param pool the pool this thread works in
     * @throws NullPointerException if pool is null
     */
    protected MicrometerWrappedForkJoinWorkerThread(final ForkJoinPool pool) {
      super(pool);
    }
  }
}

Recommend Projects