Я пытаюсь понять язык Го.Я попытался создать две процедуры, которые объединяют поток между ними, используя два канала:
func main() {
c1 := make(chan int)
c2 := make(chan int)
go func() {
for i := range c1{
println("G1 got", i)
c2 <- i
}
}()
go func() {
for i := range c2 {
println("G2 got", i)
c1 <- i
}
}()
c1 <- 1
time.Sleep(1000000000 * 50)
}
Как и ожидалось, этот код печатает:
G1 got 1
G2 got 1
G1 got 1
G2 got 1
....
Пока не завершится основная функция.
Но если я отправлю другое значение на один из каналов из основного, он внезапно блокирует:
func main() {
c1 := make(chan int)
c2 := make(chan int)
go func() {
for i := range c1{
println("G1 got", i)
c2 <- i
}
}()
go func() {
for i := range c2 {
println("G2 got", i)
c1 <- i
}
}()
c1 <- 1
time.Sleep(1000000000 * 1)
c1 <- 2
time.Sleep(1000000000 * 50)
}
Он выводит
G1 got 1
G2 got 1
G1 got 1
G2 got 1
G1 got 2
, а затем блокирует, пока основное не закончится.
Значение "2", отправленное на c1, поступает в первый goroutie, которое отправляет его в c2, но вторая программа никогда не получает.
(Использование буферизованных каналов с размером 1 (c1 или c2)работает в этом примере)
Почему это происходит?Когда это происходит в реальном коде, как я могу его отладить?