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)); + } +}