分享
go语言生产者,消费者事例
eclipser1987 · · 6190 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
package main
import "fmt"
import "time"
func main() {
// ch := make(chan int, 10)
ch := make(chan int)
go produce("生产者1",ch)
go produce("生产者2",ch)
time.Sleep(1 * time.Second)
go use(ch)
time.Sleep(101 * time.Second)
}
func produce(pname string,ch chan int) {
for i:= 0;i < 20;i++ {
fmt.Println("produce", pname ," : ", i)
ch <- i // 这里需要在打印语句之后,否者可能产生理解歧义
time.Sleep(1 * time.Second)
}
}
func use(ch chan int) {
var i int
loop1:
i = <-ch
fmt.Println("use : ",i )
goto loop1
}
以上代码有很多细节上的不完善的地方,修改:
package main
import "fmt"
import "time"
func main() {
// ch := make(chan int, 10)
ch := make(chan int)
defer close(ch)
go produce("生产者1",ch)
go produce("生产者2",ch)
time.Sleep(1 * time.Second)
go use(ch)
time.Sleep(30 * time.Second)
}
func produce(pname string,ch chan int) {
for i:= 0;i < 20;i++ {
fmt.Println("produce", pname ," : ", i)
ch <- i
time.Sleep(1 * time.Second)
}
}
func use(ch chan int) {
for i := range ch {
fmt.Println("use : ",i )
}
}
多个生产者,多个消费者
package main
import "fmt"
import "time"
func main() {
// ch := make(chan int, 10)
ch := make(chan int)
defer close(ch)
go produce("生产者1", ch)
go produce("生产者2", ch)
time.Sleep(1 * time.Second)
go use("消费者1", ch)
go use("消费者2", ch)
time.Sleep(30 * time.Second)
}
func produce(pname string, ch chan int) {
for i := 0; i < 20; i++ {
fmt.Println("produce", pname, " : ", i)
ch <- i
time.Sleep(1 * time.Second)
}
}
func use(uname string, ch chan int) {
for i := range ch {
fmt.Println("use", uname, " : ", i)
}
}
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信6190 次点击
上一篇:GO 使用MySQL数据库
下一篇:golang中的数组切片
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
package main
import "fmt"
import "time"
func main() {
// ch := make(chan int, 10)
ch := make(chan int)
go produce("生产者1",ch)
go produce("生产者2",ch)
time.Sleep(1 * time.Second)
go use(ch)
time.Sleep(101 * time.Second)
}
func produce(pname string,ch chan int) {
for i:= 0;i < 20;i++ {
fmt.Println("produce", pname ," : ", i)
ch <- i // 这里需要在打印语句之后,否者可能产生理解歧义
time.Sleep(1 * time.Second)
}
}
func use(ch chan int) {
var i int
loop1:
i = <-ch
fmt.Println("use : ",i )
goto loop1
}
以上代码有很多细节上的不完善的地方,修改:
package main
import "fmt"
import "time"
func main() {
// ch := make(chan int, 10)
ch := make(chan int)
defer close(ch)
go produce("生产者1",ch)
go produce("生产者2",ch)
time.Sleep(1 * time.Second)
go use(ch)
time.Sleep(30 * time.Second)
}
func produce(pname string,ch chan int) {
for i:= 0;i < 20;i++ {
fmt.Println("produce", pname ," : ", i)
ch <- i
time.Sleep(1 * time.Second)
}
}
func use(ch chan int) {
for i := range ch {
fmt.Println("use : ",i )
}
}
多个生产者,多个消费者
package main
import "fmt"
import "time"
func main() {
// ch := make(chan int, 10)
ch := make(chan int)
defer close(ch)
go produce("生产者1", ch)
go produce("生产者2", ch)
time.Sleep(1 * time.Second)
go use("消费者1", ch)
go use("消费者2", ch)
time.Sleep(30 * time.Second)
}
func produce(pname string, ch chan int) {
for i := 0; i < 20; i++ {
fmt.Println("produce", pname, " : ", i)
ch <- i
time.Sleep(1 * time.Second)
}
}
func use(uname string, ch chan int) {
for i := range ch {
fmt.Println("use", uname, " : ", i)
}
}