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 创建型设计模式抽象工厂

手撸Golang 行为型设计模式状态模式

[系列] Go - 统一定义 api 错误码

Go-carbon 1.3.2 版本发布，新增自定义 i18n 系列方法和日文翻译文件

手撸Golang 行为型设计模式观察者模式

29 Golang反射与底层编程

分布式定时任务执行器

17 Golang结构体详解（三）