Closed nodece closed 1 month ago
We currently use chan []*message as queueCh, and use the slice to stage the messages to send the message to the parent consumer, this will result in excessive use of memory.
chan []*message
This PR optimizes potentially reducing overall memory overhead.
chan *message
Motivation
We currently use
chan []*message
as queueCh, and use the slice to stage the messages to send the message to the parent consumer, this will result in excessive use of memory.This PR optimizes potentially reducing overall memory overhead.
Modifications
chan *message
instead ofchan []*message
.