嘗試安排專案，將專案發送到“狀態”通道以獲取狀態，然后將專案發送到“洗掉”通道以洗掉專案。我正在設定兩個通道的大小，預計在專案洗掉完成后我會“完成”。在“完成”之前執行“洗掉”之后，代碼似乎正在停止。為什么我會收到“致命錯誤：所有 goroutines 都睡著了 - 死鎖！” 在“洗掉專案”之后和“完成”之前？哪個例程正在睡覺？
https://go.dev/play/p/W49niF5xngQ
package main
import (
"fmt"
"time"
)
func main() {
numbers := []int{1, 2, 4}
for _, n := range numbers {
fmt.Printf("Schedule and delete %d items.\n", n)
statusChan := make(chan string, n)
deleteChan := make(chan string, n)
done := make(chan bool)
go func(n int, statusChan chan<- string) {
for i := 0; i < n; i {
i := i
go func(n int, statusChan chan<- string) {
fmt.Printf("Scheduling item number ... %d\n", i)
itemNum := fmt.Sprintf("item_num_%d\n", i)
time.Sleep(500 * time.Millisecond)
statusChan <- itemNum
}(n, statusChan)
}
}(n, statusChan)
go func(statusChan <-chan string, deleteChan chan<- string) {
for itemNum := range statusChan {
fmt.Printf("Checking status of item number ... %s\n", itemNum)
time.Sleep(500 * time.Millisecond)
deleteChan <- itemNum
}
}(statusChan, deleteChan)
go func(deleteChan <-chan string, done chan<- bool) {
for itemNum := range deleteChan {
fmt.Printf("Delete item: %s", itemNum)
time.Sleep(500 * time.Millisecond)
}
fmt.Printf("Done with scheduling and deleting %d item.\n", n)
done <- true
}(deleteChan, done)
<-done
}
}
uj5u.com熱心網友回復：
這似乎符合您的想法。我使用“***”作為“全部完成”的信號。
package main
import (
"fmt"
"time"
)
func main() {
numbers := []int{1, 2, 4}
for _, n := range numbers {
fmt.Printf("Schedule and delete %d items.\n", n)
statusChan := make(chan string, n)
deleteChan := make(chan string, n)
done := make(chan bool)
go func(n int, statusChan chan<- string) {
for i := 0; i < n; i {
fmt.Printf("Scheduling item number ... %d\n", i)
itemNum := fmt.Sprintf("item_num_%d\n", i)
time.Sleep(500 * time.Millisecond)
statusChan <- itemNum
}
statusChan <- "***"
}(n, statusChan)
go func(statusChan <-chan string, deleteChan chan<- string) {
for itemNum := range statusChan {
fmt.Printf("Checking status of item number ... %s\n", itemNum)
deleteChan <- itemNum
}
}(statusChan, deleteChan)
go func(deleteChan <-chan string, done chan<- bool) {
for itemNum := range deleteChan {
if itemNum == "***" {
break
}
fmt.Printf("Delete item: %s", itemNum)
}
fmt.Printf("Done with scheduling and deleting %d item.\n", n)
done <- true
}(deleteChan, done)
<-done
}
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/qukuanlian/535737.html
標籤：去