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

Use offer instead of add when trying to test-insert element into the queue on ThreadPoolExecutor instrumentation

This commit is contained in:
Nikolay Martynov 2018-10-24 15:13:40 -04:00
parent faad1d92b0
commit aba0c3377d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ThreadPoolExecutorInstrumentation.java
View File

@ -54,9 +54,9 @@ public class ThreadPoolExecutorInstrumentation extends Instrumenter.Default {
if (queue.size() == 0) { if (queue.size() == 0) {
try { try {
queue.add(new GenericRunnable()); queue.offer(new GenericRunnable());
queue.clear(); // Remove the Runnable we just added. queue.clear(); // Remove the Runnable we just added.
} catch (final ClassCastException e) { } catch (final ClassCastException | IllegalArgumentException e) {
ExecutorInstrumentation.ConcurrentUtils.disableExecutor(executor); ExecutorInstrumentation.ConcurrentUtils.disableExecutor(executor);
} }
} }