golang 协程并发编程


本文摘自网络,作者,侵删。


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 实现交叉编译

在 bigcache 中存储任意类型(interface{})

Go + websocket 快速实现一个 chat 服务

性能优化+架构迭代升级 Go读书社区web开发与架构优化

Golang如何读取文件是否存在

arts #5

protoc 插件编写之一 (protoc 插件的原理)

asta:是什么终结了我的鸽王生涯?Go 1.13 发布!

Golang的内存管理(下篇)

更多相关阅读请进入《Go》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...