Method IterBuffered

BaseServer/concurrentHashMap.go:200–209

Returns a buffered iterator which could be used in a for range loop. 相当于所有的值都缓存在channel中

()

// Returns a buffered iterator which could be used in a for range loop.
// 相当于所有的值都缓存在channel中
func (m ConcurrentHashMap) IterBuffered() <-chan Tuple {
	chans := snapshot(m)
	total := 0
	for _, c := range chans {
		total += cap(c)
	}
	ch := make(chan Tuple, total)
	go fanIn(chans, ch)
	return ch
}

// Returns a array of channels that contains elements in each shard,
// which likely takes a snapshot of `m`.