调整：asyncLocal自动释放功能

farseer-go · Jul 15, 2024 · 6db8cf6 · 6db8cf6
1 parent 2c50e8c
commit 6db8cf6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/invokeJob.go b/invokeJob.go
@@ -67,7 +67,6 @@ func invokeJob(task TaskEO) {
 }
 
 func (receiver *Job) Run() {
-	asyncLocal.Release()
 	// 链路追踪
 	entryFSchedule := receiver.traceManager.EntryFSchedule(receiver.jobContext.Name, receiver.jobContext.Id, receiver.jobContext.Data.ToMap())
 	defer func() {
@@ -82,6 +81,7 @@ func (receiver *Job) Run() {
 		if entryFSchedule != nil {
 			entryFSchedule.End()
 		}
+		asyncLocal.Release()
 	}()
 
 	taskStartAtSince := time.Since(receiver.jobContext.StartAt)