Method IterCb

BaseServer/concurrentHashMap.go:275–284

Callback based iterator, cheapest way to read all elements in a map. 传入一个回调函数，目前map中的每个值都会调用这个回调

(fn IterCb)

// all elements in a map.
// 传入一个回调函数，目前map中的每个值都会调用这个回调
func (m ConcurrentHashMap) IterCb(fn IterCb) {
	for idx := range m.ThreadSafeHashMap {
		shard := (m.ThreadSafeHashMap)[idx]
		shard.RLock()
		for key, value := range shard.items {
			fn(key, value)
		}
		shard.RUnlock()
	}
}

// Return all keys as []string
// 这个貌似不对 可能channel会阻塞，因为count结束以后可能会传入值，导致这里channel阻塞