我正在学习 go 并发,我希望两个 go 例程能够继续相互通信,同时通过通道传递更新的值。一个加 2,另一个减 1。代码和输出如下:
这段代码有什么问题?
package main
import (
"fmt"
"sync"
"time"
)
var wg sync.WaitGroup
func addTwo(r chan int, e chan int) {
val := <-r
fmt.Println("AT Recieved: ", val)
time.Sleep(1 * time.Second)
e <- val + 2
}
func subtractOne(r chan int, e chan int) {
val := <-r
fmt.Println("SO Recieved: ", val)
time.Sleep(1 * time.Second)
e <- val - 1
}
func main() {
ch := make(chan int)
ch2 := make(chan int)
wg.Add(1)
go addTwo(ch, ch2)
wg.Add(1)
go subtractOne(ch2, ch)
ch <- 1
wg.Wait()
}
输出:
AT Recieved: 1
SO Recieved: 3
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [semacquire]:
sync.runtime_Semacquire(0x4b2de8?)
/usr/lib/go-1.18/src/runtime/sema.go:56 +0x25
sync.(*WaitGroup).Wait(0x0?)
/usr/lib/go-1.18/src/sync/waitgroup.go:136 +0x52
main.main()
然后它就退出了。
为什么即使我没有在 goroutines 中调用 wg.Done(),goroutine 也不会永远交换值?
您启动的两个 goroutine 都只接收一个值并发送一个值,然后结束。从那里开始,只有
main
goroutine,在 wg.Wait()
被阻塞,因为你从不调用 wg.Done()
。
你忘记使用(n无限)循环:
func addTwo(r chan int, e chan int) {
for {
val := <-r
fmt.Println("AT Recieved: ", val)
time.Sleep(1 * time.Second)
e <- val + 2
}
}
func subtractOne(r chan int, e chan int) {
for {
val := <-r
fmt.Println("SO Recieved: ", val)
time.Sleep(1 * time.Second)
e <- val - 1
}
}
通过此更改,您的应用程序将永远运行,输出为:
AT Recieved: 1
SO Recieved: 3
AT Recieved: 2
SO Recieved: 4
AT Recieved: 3
SO Recieved: 5
AT Recieved: 4
....