mirror of
https://github.com/chai2010/advanced-go-programming-book.git
synced 2025-05-24 12:32:21 +00:00
修改ch1-06笔误
This commit is contained in:
parent
25e5062c19
commit
4384c8e5a7
@ -139,13 +139,13 @@ Go语言实现生产者消费者并发很简单:
|
|||||||
// 生产者: 生成 factor 整数倍的序列
|
// 生产者: 生成 factor 整数倍的序列
|
||||||
func Producer(factor int, out chan<- int) {
|
func Producer(factor int, out chan<- int) {
|
||||||
for i := 0; ; i++ {
|
for i := 0; ; i++ {
|
||||||
item <- i*factor
|
out <- i*factor
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 消费者
|
// 消费者
|
||||||
func Consumer(in <-chan int) {
|
func Consumer(in <-chan int) {
|
||||||
for _, v := range in {
|
for v := range in {
|
||||||
fmt.Println(v)
|
fmt.Println(v)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -174,9 +174,9 @@ func main() {
|
|||||||
go Consumer(ch) // 消费 生成的队列
|
go Consumer(ch) // 消费 生成的队列
|
||||||
|
|
||||||
// Ctrl+C 退出
|
// Ctrl+C 退出
|
||||||
ch := make(chan os.Signal, 1)
|
sig := make(chan os.Signal, 1)
|
||||||
signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
|
signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
|
||||||
fmt.Printf("quit (%v)\n", <-ch)
|
fmt.Printf("quit (%v)\n", <-sig)
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user