|
@@ -372,7 +372,7 @@ func (c *MQTTCoupler) startExecutorReaper(interval, timeout time.Duration) {
|
|
|
idle := (ce.state == execIdle)
|
|
idle := (ce.state == execIdle)
|
|
|
ce.mu.Unlock()
|
|
ce.mu.Unlock()
|
|
|
|
|
|
|
|
- if expired && idle { // 超时且执行器状态空闲, 回收该执行器
|
|
|
|
|
|
|
+ if expired && idle { // 超时且状态空闲时则回收
|
|
|
ce.handleClose()
|
|
ce.handleClose()
|
|
|
delete(c.executorMap, id)
|
|
delete(c.executorMap, id)
|
|
|
} // end if
|
|
} // end if
|