push consumer may have concurrency issue for the map which used by control the goroutine numbers

**BUG REPORT**  
1. Please describe the issue you observed:

    -  push consumer may have concurrency issue for the map `crCh                         map[string]chan struct{}`

2. Please tell us about your environment:

the newest go client version

3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
