package?csp

import?(
????"fmt"
????"sync"
????"testing"
)

/*?func?dataProducer(ch?chan?int,?wg?*sync.WaitGroup)?{
????go?func()?{
????????for?i?:=?0;?i?go??test
0
1
2
3
4
5
6
7
8
9
PASS
ok????????0.249s

>?*/

/*
func?TestChannelClose(t?*testing.T)?{
????ch?:=?make(chan?int)
????var?wg?sync.WaitGroup
????wg.Add(1)
????dataProducer(ch,?&wg)
????wg.Add(1)
????dataReceiver(ch,?&wg)
????wg.Add(1)
????dataReceiver(ch,?&wg)
????wg.Add(1)
????dataReceiver(ch,?&wg)
????wg.Wait()
}
>go??test
0
1
4
5
6
7
8
9
3
2
PASS
ok????????0.360s

>?*/