本文摘自网络,作者,侵删。
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
}
}
本文来自:简书
感谢作者:Ucan先生
查看原文:golang 协程并发编程
相关阅读 >>
手撸Golang Go与微服务 chatserver之4 内存泄漏
Google官宣:新一代操作系统fuchsia编程语言竟然是它!
更多相关阅读请进入《Go》频道 >>
Go语言101
一个与时俱进的Go编程知识库。