fix(session): prevent duplicate execution with external scheduler factory

timandy · timandy · commit 2a6f7d94ddb6 · 2025-08-06T20:00:41.000+08:00
diff --git a/session/session.go b/session/session.go
@@ -461,11 +461,8 @@ func (s *Session) Execute(task func(), executorFactory ...func() schedulerapi.Ex
 			continue
 		}
 		executor = fac()
-		if executor == nil {
-			continue
-		}
-		if !executor.Execute(task) {
-			continue
+		if executor != nil && executor.Execute(task) {
+			return
 		}
 	}
 	// 全局级别执行器

Original file line number	Diff line number	Diff line change
`@@ -461,11 +461,8 @@ func (s *Session) Execute(task func(), executorFactory ...func() schedulerapi.Ex`
`461`	`461`	`continue`
`462`	`462`	`}`
`463`	`463`	`executor = fac()`
`464`		`- if executor == nil {`
`465`		`- continue`
`466`		`- }`
`467`		`- if !executor.Execute(task) {`
`468`		`- continue`
	`464`	`+ if executor != nil && executor.Execute(task) {`
	`465`	`+ return`
`469`	`466`	`}`
`470`	`467`	`}`
`471`	`468`	`// 全局级别执行器`