chore(ringqueue): gc overhead

appleboy · appleboy · commit c65a57a76b98 · 2023-01-20T16:36:09.000+08:00
Signed-off-by: Bo-Yi.Wu &lt;appleboy.tw@gmail.com&gt;
diff --git a/consumer.go b/consumer.go
@@ -83,6 +83,7 @@ func (s *Consumer) Request() (core.QueuedMessage, error) {
 	}
 	s.Lock()
 	data := s.taskQueue[s.head]
+	s.taskQueue[s.head] = nil
 	s.head = (s.head + 1) % len(s.taskQueue)
 	s.count--
 

Original file line number	Diff line number	Diff line change
`@@ -83,6 +83,7 @@ func (s *Consumer) Request() (core.QueuedMessage, error) {`
`83`	`83`	`}`
`84`	`84`	`s.Lock()`
`85`	`85`	`data := s.taskQueue[s.head]`
	`86`	`+ s.taskQueue[s.head] = nil`
`86`	`87`	`s.head = (s.head + 1) % len(s.taskQueue)`
`87`	`88`	`s.count--`
`88`	`89`