From 300dd49c62b8b498af693daad02696387b033afb Mon Sep 17 00:00:00 2001
From: zendwang <wangzhenxian0556@126.com>
Date: Fri, 26 Mar 2021 17:05:05 +0800
Subject: [PATCH] =?UTF-8?q?enhancement=20#I3CTUK=20=E6=AF=8F=E4=B8=AA?=
 =?UTF-8?q?=E7=BB=84=E4=BB=B6=E7=9A=84=E5=AF=B9slot=20index=E7=9A=84?=
 =?UTF-8?q?=E5=AD=98=E5=82=A8=EF=BC=8C=E6=8D=A2=E6=88=90=E9=98=BF=E9=87=8C?=
 =?UTF-8?q?=E7=9A=84TTL?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 liteflow-core/pom.xml                                     | 4 ++++
 .../java/com/yomahub/liteflow/core/NodeComponent.java     | 8 +++-----
 pom.xml                                                   | 6 ++++++
 3 files changed, 13 insertions(+), 5 deletions(-)

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 @@
 			<groupId>org.apache.curator</groupId>
 			<artifactId>curator-recipes</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>transmittable-thread-local</artifactId>
+		</dependency>
 	</dependencies>
 </project>
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<Integer> slotIndexTL = new InheritableThreadLocal<Integer>();
+	private TransmittableThreadLocal<Integer> slotIndexTL = new TransmittableThreadLocal<Integer>();
 
 	@Autowired(required = false)
 	private MonitorBus monitorBus;
@@ -44,7 +42,7 @@ public abstract class NodeComponent {
 	private String nodeId;
 
 	//是否结束整个流程，这个只对串行流程有效，并行流程无效
-	private InheritableThreadLocal<Boolean> isEndTL = new InheritableThreadLocal<>();
+	private TransmittableThreadLocal<Boolean> 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 @@
 		<curator.version>2.12.0</curator.version>
 		<junit.version>4.12</junit.version>
 		<hutool-core.version>5.3.10</hutool-core.version>
+		<transmittable-thread-local.version>2.12.1</transmittable-thread-local.version>
     </properties>
 
     <dependencyManagement>
@@ -125,6 +126,11 @@
 				<artifactId>hutool-core</artifactId>
 				<version>${hutool-core.version}</version>
 			</dependency>
+			<dependency>
+				<groupId>com.alibaba</groupId>
+				<artifactId>transmittable-thread-local</artifactId>
+				<version>${transmittable-thread-local.version}</version>
+			</dependency>
 		</dependencies>
 	</dependencyManagement>