diff --git a/sm.go b/sm.go index 2579091..5a6e063 100644 --- a/sm.go +++ b/sm.go @@ -23,8 +23,7 @@ type SMQueue struct { // 互斥锁,保护队列Map的并发访问 mu *sync.Mutex // 组名到队列的映射 - queues map[string]*PriorityQueue[QueueItem] - + queues map[string]*PriorityQueue[QueueItem] counter *triggered.EventExecute[int64] } @@ -59,7 +58,6 @@ func NewSMQueue(shardID uint64, replicaID uint64) sm.IStateMachine { // we always return the Count value as a little endian binary encoded byte // slice. func (s *SMQueue) Lookup(group interface{}) (item interface{}, err error) { - return item, nil }