func (q *pubQueue) Size() int {
	q.mu.RLock()
	s := q.size
	q.mu.RUnlock()
	return s
}
// Return the current size of the queue.
Return the current size of the queue.
// Return the current size of the queue .
func (q *pubQueue) Size() int {
	q.mu.RLock()
	s := q.size
	q.mu.RUnlock()
	return s
}
func ( q * pubQueue ) Size ( ) int { q . mu . RLock ( ) s := q . size q . mu . RUnlock ( ) return s }
Return the current size of the queue.
Return the current size of the queue .