如何在消耗相同通道的循環(huán)內(nèi)裝配通道。下面是一個(gè)不起作用的示例代碼。這是如何實(shí)現(xiàn)的？https://go.dev/play/p/o5ZhNfw4IFupackage mainimport ( "context" "fmt" "time")func main() { ch1 := make(chan struct{}) ch2 := make(chan struct{}) defer close(ch1) defer close(ch2) ctx, cancel := context.WithTimeout(context.Background(), time.Second*3) defer cancel() go func() { time.Sleep(time.Second * 1) ch1 <- struct{}{} }()loop: for { select { case <-ctx.Done(): fmt.Println("timeout") break loop case <-ch1: fmt.Println("ch1") ch2 <- struct{}{} // This here does not work! case <-ch2: fmt.Println("ch2") } }}去
1 回答
泛舟湖上清波郎朗
TA貢獻(xiàn)1818條經(jīng)驗(yàn) 獲得超3個(gè)贊
1.發(fā)送數(shù)據(jù)到goroutine里面的ch2
package main
import (
"context"
"fmt"
"time"
)
func main() {
ch1 := make(chan struct{})
ch2 := make(chan struct{})
defer close(ch1)
defer close(ch2)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
defer cancel()
go func() {
time.Sleep(time.Second * 1)
ch1 <- struct{}{}
}()
loop:
for {
select {
case <-ctx.Done():
fmt.Println("timeout")
break loop
case <-ch1:
fmt.Println("ch1")
go func() {
ch2 <- struct{}{}
}()
case <-ch2:
fmt.Println("ch2")
}
}
}
或者
2. 使 ch2 緩沖
package main
import (
"context"
"fmt"
"time"
)
func main() {
ch1 := make(chan struct{})
ch2 := make(chan struct{}, 1)
defer close(ch1)
defer close(ch2)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
defer cancel()
go func() {
time.Sleep(time.Second * 1)
ch1 <- struct{}{}
}()
loop:
for {
select {
case <-ctx.Done():
fmt.Println("timeout")
break loop
case <-ch1:
fmt.Println("ch1")
ch2 <- struct{}{}
case <-ch2:
fmt.Println("ch2")
}
}
}
- 1 回答
- 0 關(guān)注
- 128 瀏覽
添加回答
舉報(bào)
0/150
提交
取消