fix(task): memory alignment for curID (close #2541)

This commit is contained in:
Noah Hsu 2022-12-01 13:16:31 +08:00
parent ff0bcfef8a
commit 18a63e34dd

View File

@ -8,8 +8,8 @@ import (
) )
type Manager[K comparable] struct { type Manager[K comparable] struct {
workerC chan struct{}
curID K curID K
workerC chan struct{}
updateID func(*K) updateID func(*K)
tasks generic_sync.MapOf[K, *Task[K]] tasks generic_sync.MapOf[K, *Task[K]]
} }
@ -94,7 +94,7 @@ func (tm *Manager[K]) RemoveByStates(states ...string) {
tasks := tm.GetAll() tasks := tm.GetAll()
for _, task := range tasks { for _, task := range tasks {
if utils.SliceContains(states, task.GetState()) { if utils.SliceContains(states, task.GetState()) {
tm.Remove(task.ID) _ = tm.Remove(task.ID)
} }
} }
} }