open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Avoid RejectedExecutionException (#7516) 

TIL (in another repo but applicable here)
This commit is contained in:
Trask Stalnaker 2023-01-09 13:22:57 -08:00 committed by GitHub
parent f0bd7c0504
commit ecacd8c86b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
instrumentation-api/src/main/java/io/opentelemetry/instrumentation/api/internal/SupportabilityMetrics.java
View File

@ -9,6 +9,7 @@ import io.opentelemetry.api.trace.SpanKind;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import java.util.function.Consumer; import java.util.function.Consumer;
@ -84,15 +85,24 @@ public final class SupportabilityMetrics {
@SuppressWarnings("CanIgnoreReturnValueSuggester") @SuppressWarnings("CanIgnoreReturnValueSuggester")
private SupportabilityMetrics start() { private SupportabilityMetrics start() {
if (agentDebugEnabled) { if (agentDebugEnabled) {
Executors.newScheduledThreadPool( ScheduledExecutorService executor =
Executors.newScheduledThreadPool(
1, 1,
runnable -> { runnable -> {
Thread result = new Thread(runnable, "supportability_metrics_reporter"); Thread result = new Thread(runnable, "supportability_metrics_reporter");
result.setDaemon(true); result.setDaemon(true);
result.setContextClassLoader(null); result.setContextClassLoader(null);
return result; return result;
}) });
.scheduleAtFixedRate(this::report, 5, 5, TimeUnit.SECONDS); executor.scheduleAtFixedRate(this::report, 5, 5, TimeUnit.SECONDS);
// the condition below will always be false, but by referencing the executor it ensures the
// executor can't become unreachable in the middle of the scheduleAtFixedRate() method
// execution above (and prior to the task being registered), which can lead to the executor
// being terminated and scheduleAtFixedRate throwing a RejectedExecutionException
// (see https://bugs.openjdk.org/browse/JDK-8145304)
if (executor.isTerminated()) {
throw new AssertionError();
}
} }
return this; return this;
} }