From 9e55f27661fc0448d2363ff79fc725a590a404e7 Mon Sep 17 00:00:00 2001 From: xYohn <26292685+xyohn@users.noreply.github.com> Date: Thu, 7 Dec 2023 15:30:00 +0800 Subject: [PATCH] =?UTF-8?q?Support=20`java.util.concurrent.Executor`=20?= =?UTF-8?q?=EF=BC=88#515)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tracer/core/async/SofaTraceExecutor.java | 32 +++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 tracer-core/src/main/java/com/alipay/common/tracer/core/async/SofaTraceExecutor.java diff --git a/tracer-core/src/main/java/com/alipay/common/tracer/core/async/SofaTraceExecutor.java b/tracer-core/src/main/java/com/alipay/common/tracer/core/async/SofaTraceExecutor.java new file mode 100644 index 00000000..f7a3c353 --- /dev/null +++ b/tracer-core/src/main/java/com/alipay/common/tracer/core/async/SofaTraceExecutor.java @@ -0,0 +1,32 @@ +package com.alipay.common.tracer.core.async; + +import java.util.concurrent.Executor; +import java.util.concurrent.RejectedExecutionException; + +/** + * @author xYohn + * @date 2023/12/7 + */ +public class SofaTraceExecutor implements Executor { + + private final Executor delegate; + + public SofaTraceExecutor(Executor delegate) { + this.delegate = delegate; + } + + /** + * Executes the given command at some time in the future. The command + * may execute in a new thread, in a pooled thread, or in the calling + * thread, at the discretion of the {@code Executor} implementation. + * + * @param command the runnable task + * @throws RejectedExecutionException if this task cannot be + * accepted for execution + * @throws NullPointerException if command is null + */ + @Override + public void execute(Runnable command) { + delegate.execute(new SofaTracerRunnable(command)); + } +}