英文:
Trigger a channel inside the loop where the the channel is consumed
问题
如何在循环内部触发一个消费相同通道的通道。下面是一个不起作用的示例代码。如何实现这个目标？
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")
ch2 <- struct{}{} // 这里不起作用！
case <-ch2:
fmt.Println("ch2")
}
}
}
英文:
How to rigger a channel inside the loop where the same channel is consumed. Below is a sample code that does not work. How is this achievable?
https://go.dev/play/p/o5ZhNfw4IFu
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")
ch2 <- struct{}{} // This here does not work!
case <-ch2:
fmt.Println("ch2")
}
}
}
答案1
得分: 1
1. 在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("超时")
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("超时")
break loop
case <-ch1:
fmt.Println("ch1")
ch2 <- struct{}{}
case <-ch2:
fmt.Println("ch2")
}
}
}
英文:
1. send data to ch2 inside goroutine
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")
}
}
}
or
2. make ch2 buffered
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")
}
}
}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论