Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package main
- func main() {
- cp := 2
- ch := make(chan string, cp)
- for i := 0; i < cp; i++ {
- go send(ch)
- }
- go send(ch)
- for lc := range ch {
- print(lc)
- }
- }
- func send(ch chan string) {
- ch <- "hellon"
- }
- func send(c chan string, wg *sync.WaitGroup) {
- defer wg.Done()
- // ...
- }
- wg := &sync.WaitGroup{}
- for i := 0; i < cp; i++ {
- wg.Add(1)
- go send(ch, wg)
- }
- wg.Add(1)
- go send(ch, wg)
- wg.Wait()
- close(ch)
- for e := range(ch) {
- // ...
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement