From 5c892e1f0e0c5f793e0904dbdb7254294ba06a84 Mon Sep 17 00:00:00 2001 From: eson <9673575+githubcontent@user.noreply.gitee.com> Date: Wed, 9 Aug 2023 19:02:32 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sm.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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 }