package main
import (
"fmt"
"strconv"
"time"
)
type Task struct {
Name string
Cnt int
}
var taskChan = make(chan Task,1000)
var retChan = make(chan Task,1000)
func main() {
go startRoutines(10000)
go handlResult()
go produce()
time.Sleep(1*time.Minute)
}
func startRoutines(n int) {
for i:=0;i<n;i++{
go doSomeThing()
}
}
func handlResult() {
for {
select {
case r := <- retChan:
fmt.Println(r)
}
}
}
func doSomeThing() {
for {
select{
case t := <-taskChan:
for i:=0;i<1000000;i++{
t.Cnt++
}
retChan <- t
}
}
}
func produce() {
for i:=0;i<100000;i++{
t := Task{
Name: "task_"+strconv.Itoa(i),
Cnt: i,
}
taskChan <- t
}
}
golang 协程并发编程
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
