diff --git a/liteflow-core/pom.xml b/liteflow-core/pom.xml index bab2fb518..1cd1e781b 100644 --- a/liteflow-core/pom.xml +++ b/liteflow-core/pom.xml @@ -76,5 +76,9 @@ org.apache.curator curator-recipes + + com.alibaba + transmittable-thread-local + diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java b/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java index 264c20b3f..927e4a17a 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/core/NodeComponent.java @@ -10,7 +10,7 @@ package com.yomahub.liteflow.core; import cn.hutool.core.date.StopWatch; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; - +import com.alibaba.ttl.TransmittableThreadLocal; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -26,8 +26,6 @@ import com.yomahub.liteflow.flow.FlowBus; import com.yomahub.liteflow.monitor.MonitorBus; import com.yomahub.liteflow.spring.ComponentScaner; - - /** * 普通组件抽象类 * @author Bryan.Zhang @@ -36,7 +34,7 @@ public abstract class NodeComponent { private static final Logger LOG = LoggerFactory.getLogger(NodeComponent.class); - private InheritableThreadLocal slotIndexTL = new InheritableThreadLocal(); + private TransmittableThreadLocal slotIndexTL = new TransmittableThreadLocal(); @Autowired(required = false) private MonitorBus monitorBus; @@ -44,7 +42,7 @@ public abstract class NodeComponent { private String nodeId; //是否结束整个流程,这个只对串行流程有效,并行流程无效 - private InheritableThreadLocal isEndTL = new InheritableThreadLocal<>(); + private TransmittableThreadLocal isEndTL = new TransmittableThreadLocal<>(); public void execute() throws Exception{ Slot slot = this.getSlot(); diff --git a/pom.xml b/pom.xml index 3a25ea5cf..9ab409d0e 100644 --- a/pom.xml +++ b/pom.xml @@ -51,6 +51,7 @@ 2.12.0 4.12 5.3.10 + 2.12.1 @@ -125,6 +126,11 @@ hutool-core ${hutool-core.version} + + com.alibaba + transmittable-thread-local + ${transmittable-thread-local.version} +