Goroutine池

goroutine池的应用

本质上是生产者消费者模型
可以有效控制goroutine数量，防止暴涨
需求：
- 计算一个数字的各个位数之和，例如数字123，结果为1+2+3=6
- 随机生成数字进行计算
控制台输出结果如下：

job id: 164362 random: 3002688297310473558 result: 81
job id: 164363 random: 8188014692039052954 result: 84
job id: 164364 random: 9199514953162082256 result: 87
job id: 164365 random: 6547609431377245779 result: 96
job id: 164366 random: 5158862497998501304 result: 94
job id: 164367 random: 7591045689235318611 result: 84
job id: 164368 random: 4913457935486468007 result: 93
job id: 164369 random: 6484925446766292271 result: 94
job id: 164370 random: 1630566468428792798 result: 101
job id: 164371 random: 3999715154713986432 result: 96
job id: 164372 random: 8436839935373284876 result: 106
job id: 164373 random: 7590654756672405712 result: 88
job id: 164374 random: 5127823813978664887 result: 103
job id: 164375 random: 5630536624069526117 result: 77
job id: 164376 random: 3445557283367509019 result: 86
job id: 164377 random: 6087330610397339825 result: 83
job id: 164378 random: 3391465925899927215 result: 99

main.go

package mainimport ("fmt""math/rand"
)type Job struct {Id intRandom int
}type Result struct {job *Jobsum int
}func createGoroutinePool(goNum int, jobChan chan *Job, resultChan chan *Result){// 根据goNum开启多个goroutine执行for i := 0; i < goNum; i++ {go func(jobChan chan *Job, resultChan chan *Result) {// 处理每个jobChan中的数据并返回结果for job := range jobChan{random := job.Randomvar sum int// 计算每一位的和for random != 0 {tmp := random % 10sum += tmprandom /= 10}// 组织返回结果r := &Result{job: job,sum: sum,}// 将结果写入通道resultChan<- r}}(jobChan, resultChan)}
}func main() {// 工作通道jobChan := make(chan *Job, 128)// 结果通道resultChan := make(chan *Result,128)// 创建工作池执行任务createGoroutinePool(64, jobChan, resultChan)// 打印结果通道数据go func(resultChan chan *Result){for result := range resultChan{fmt.Printf("job id: %v random: %v result: %d\n", result.job.Id, result.job.Random, result.sum)}}(resultChan)var id intfor {id++r_num := rand.Int()job := &Job{Id:     id,Random: r_num,}jobChan<-job}
}

Goroutine池相关推荐

Goroutine 并发调度模型深度解析之手撸一个高性能 goroutine 池
文章目录 1 前言 2 Goroutine & Scheduler 2.1 线程那些事儿 2.1.1 用户级线程模型 2.1.2 内核级线程模型 2.1.3 两级线程模型 2.2 G-P-M ...
高性能goroutine池---ants(2.5.0) 源码解析
引言 ants是一个高性能的 goroutine 池,实现了对大规模 goroutine 的调度管理.goroutine 复用,允许使用者在开发并发程序的时候限制 goroutine 数量,复用资源, ...
go语言中goroutine池
创建三个goroutine,创建5个任务,用三个goroutine干5个任务 package mainimport ("fmt""time" )func wor ...
Goroutine并发调度模型深度解析之手撸一个协程池
Goroutine & Scheduler Goroutine,Go语言基于并发(并行)编程给出的自家的解决方案.goroutine是什么?通常goroutine会被当做coroutine(协 ...
Go：goroutine线程池 ants 简介与实践
文章目录简介一.功能介绍二.处理流程三.示例小结简介 github地址: https://github.com/panjf2000/ants ants是一个高性能的 goroutine 池 ...
十、Go协程的调度，互斥锁，计数器和线程池
@Author:Runsen 在字节面试中,我见过:GO语言中的协程与Python中的协程的区别?其实就是要我讲解Go中GMP机制.我表示很多都用过,但是底层不了解. 那时我只知道与传统的系统级线程和 ...
【Java并发编程】并发之痛 Thread，Goroutine，Actor
本文基于我在2月27日Gopher北京聚会演讲整理而成,进行了一些补充以及调整.投稿给<高可用架构>公众号首发. 聊这个话题之前,先梳理下两个概念,几乎所有讲并发的文章都要先讲这两个概念: ...
Golang的协程池设计
转载地址:https://studygolang.com/articles/15477 使用Go语言实现并发的协程调度池阉割版,本文主要介绍协程池的基本设计思路,目的为深入浅出快速了解协程池工作原理, ...
白话 Golang 协程池
文章目录 1.何为并发 2.并发的好处 3.Go 如何并发 4.G-P-M 调度模型 5.Go 程的代价 6.协程池的作用 7.简易协程池的设计&实现 8.开源协程池的使用 9.小结参考文献 ...

Goroutine池

Goroutine池相关推荐

最新文章

热门文章