关于golang利用channel和goroutine完成统计素数的思路

 更新时间:2021年08月20日 11:40:48   作者:墨儿舞步  
这篇文章主要介绍了golang利用channel和goroutine完成统计素数的思路详解,通过思路图分析及实例代码相结合给大家介绍的非常详细,需要的朋友可以参考下

1. 需求

要求统计1-200000的数字中,哪些是素数?这个问题在本章开篇就提出来了,可以使用goroutine和channel来完成

2.分析思路

传统的方法,就是使用一个循环,循环的判断各个数是不是素数【ok】

使用并发/并行的方式,将统计素数的任务分配给多个(x个)goroutine去完成,完成任务时间短

分析思路图:

 代码实现:

package main
import (
	"fmt"
	"time"
)
// 需求:
// 要求统计1-200000的数字,哪些是素数?这个问题在本章开篇就提出了,现在我们有goroutine和channel的知识后,就可以完成了【测试数据:80000】
// 分析思路:
// 传统的方法,就是使用一个循环,循环的判断各个数是不是素数【ok】
// 使用并发/并行的方式,将统计素数的任务分配给多个(x个)goroutine去完成,完成任务时间短
 
// 1. 向intChan放入1-8000的数字
func putNum(intChan chan int) {
	for i := 1; i <= 20000; i++ {
		intChan <- i
	}
	// 关闭intChan
	close(intChan)
}
 
// 从intChan中取出数据,并判断是否为素数,如果是,就放入到primeChan
func primeNum1(intChan chan int, primeChan chan int, exitChan chan bool) {
	// 使用for循环
	var flag bool
	for {
		time.Sleep(time.Millisecond * 10)
		num, ok := <- intChan
 
		if !ok { //intChan取不到,且关闭了管道
			break
		}
		flag = true // 假设是素数
		// 判断num是不是素数
		for i := 2; i < num; i++ {
			if num % i == 0 { // 说明该num不是素数
				flag = false
				break
			}
		}
		if flag {
			// 将这个数放到primeChan
			primeChan<- num
		}
	}
	fmt.Println("有一个prieNum 协程因为取不到数据,退出")
	// 这里我们还不能关闭primeChan
	// 向exitChan写入true
	exitChan <- true
}
func main() {
	var intChan chan int = make(chan int, 1000)
	var primeChan chan int = make(chan int,2000)
	// 标识退出的管道
	exitChan := make(chan bool,4)
	// 开启一个协程,向intChan放入 1-8000个数
	go putNum(intChan)
	// 开启4个协程,从 intChan中取出数据,并判断是否为素数,如果是就放入到primeChan
	for i := 0; i < 10000; i++ {
		go primeNum1(intChan,primeChan,exitChan)
	}
	// 这里我们主线程,进行处理
	go func() {
		for i := 0; i < 4; i++ {
			<-exitChan
		}
		// 当我们从exitChan中取出了4个结果,就可以放心的关闭primeChan
		close(primeChan)
	}()
	// 遍历我们的primeChan,把结果取出
	for {
		res, ok := <- primeChan
		if !ok {
			break
		}
		// 将结果取出
		fmt.Printf("素数=%d\n",res)
	}
	fmt.Println("main线程退出")
}

结论:使用go协程结合channel后,执行的速度,会大大 提高

go中可以轻松开启1万个协程 

到此这篇关于golang利用channel和goroutine完成统计素数的文章就介绍到这了,更多相关golang统计素数内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Go json omitempty如何实现可选属性

    Go json omitempty如何实现可选属性

    在Go语言中,使用`omitempty`可以帮助我们在进行JSON序列化和反序列化时,忽略结构体中的零值或空值,本文介绍了如何通过将字段类型改为指针类型,并在结构体的JSON标签中添加`omitempty`来实现这一功能,例如,将float32修改为*float32
    2024-09-09
  • go语言中匿名函数的作用域陷阱详解

    go语言中匿名函数的作用域陷阱详解

    GO语言的匿名函数(anonymous function),其实就是闭包.是指不需要定义函数名的一种函数实现方式,下面这篇文章主要给大家介绍了关于go语言中匿名函数作用域陷阱的相关资料,需要的朋友可以参考下
    2022-05-05
  • 简单聊一聊Go语言中的数组和切片

    简单聊一聊Go语言中的数组和切片

    数组和切片由于语法十分相似,在使用中容易混淆,要认真区分,下面这篇文章主要给大家介绍了关于Go语言中数组和切片的相关资料,需要的朋友可以参考下
    2021-07-07
  • GO Cobra Termui库开发终端命令行小工具轻松上手

    GO Cobra Termui库开发终端命令行小工具轻松上手

    这篇文章主要为大家介绍了GO语言开发终端命令行小工具,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2024-01-01
  • Golang语言中fs.ReadDir的全面指南

    Golang语言中fs.ReadDir的全面指南

    欢迎来到Golang语言中fs.ReadDir的全面指南!这个简短的引导将让你掌握如何高效地使用这个功能,一起来深入探索吧,保证你会有所收获!
    2023-12-12
  • Golang微服务框架Kratos实现分布式任务队列Asynq的方法详解

    Golang微服务框架Kratos实现分布式任务队列Asynq的方法详解

    任务队列(Task Queue) 一般用于跨线程或跨计算机分配工作的一种机制,在Golang语言里面,我们有像Asynq和Machinery这样的类似于Celery的分布式任务队列,本文就给大家详细介绍一下Golang微服务框架Kratos实现分布式任务队列Asynq的方法,需要的朋友可以参考下
    2023-09-09
  • Go语言数据结构之二叉树可视化详解

    Go语言数据结构之二叉树可视化详解

    这篇文章主要为大家详细介绍了Go语言数据结构中二叉树可视化的方法详解,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
    2022-09-09
  • Go实现文件分片上传

    Go实现文件分片上传

    这篇文章主要为大家详细介绍了Go实现文件分片上传,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-07-07
  • 浅析GO并发处理选择sync还是channel

    浅析GO并发处理选择sync还是channel

    这篇文章主要想来和大家讨论一下,GO 语言处理并发的时候我们是选择sync还是channel,文中的示例代码讲解详细,感兴趣的小伙伴可以了解下
    2023-08-08
  • 使用go备份StarRocks建表语句方法实例

    使用go备份StarRocks建表语句方法实例

    这篇文章主要为大家介绍了使用go备份StarRocks建表语句方法实例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12

最新评论