go并发实现素数筛的代码

 更新时间:2021年03月17日 10:20:32   作者:kelianlee  
这篇文章主要介绍了go并发实现素数筛的代码,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

先贴代码

package main
 
import (
	"fmt"
)
 
// Send the sequence 2, 3, 4, ... to channel 'ch'.
func generate(ch chan int) {
	for i := 2; ; i++ {
		ch <- i // Send 'i' to channel 'ch'.
	}
}
 
// Copy the values from channel 'in' to channel 'out',
// removing those divisible by 'prime'.
func filter(in, out chan int, prime int) {
	for {
		i := <-in // Receive value of new variable 'i' from 'in'.
		if i == 4{
			fmt.Println(prime)
		}
		if i%prime != 0 {
			out <- i // Send 'i' to channel 'out'.
		}
	}
}
 
// The prime sieve: Daisy-chain filter processes together.
func main() {
	ch := make(chan int) // Create a new channel.
	go generate(ch)   // Start generate() as a goroutine.
	for i:=0;i<10;i++ {
		prime := <-ch
		fmt.Println(&ch)
		fmt.Print(prime, " ")
		ch1 := make(chan int)
		go filter(ch, ch1, prime)
		ch = ch1
	}
}

第一次看这个素数筛一脸懵逼,首先我们要理解不是并发的素数筛,这个自行百度。

接下来我们看张图

这就是上面算法的流程图,我刚开始很难的理解是:为什么generate产生的2,3,4,5....等数一定是先被2筛选呢?我们知道并发有个不确定性,我们如果把generate函数当作生产者,那么2,3,5,7这几个素数过滤器协程就是消费者,根据一般的消费者生产模型,生产者产生的2,3,4,5等各个数被消费者使用的时候应该是不确定性的。

这里的关键在于generate这个channel只连接了2这个协程,并没有跟后面的协程相连接,而最秒的地方在于后面的每个协程的channel都只是与前后的协程相互通信的,这样就达到了一个串联的效果。

关键看代码filter函数的参数in,out这两个channel,in是上一个协程与当前协程所建立的channel,out则是当前协程与下一个协程所建立的channel(因为看main里面ch=ch1)

相关文章

  • Golang熔断器的开发过程详解

    Golang熔断器的开发过程详解

    Golang熔断器是一种用于处理分布式系统中服务调用的故障保护机制,它可以防止故障服务的连锁反应,提高系统的稳定性和可靠性,本文将给大家详细的介绍一下Golang熔断器的开发过程,需要的朋友可以参考下
    2023-09-09
  • Go语言读取文件的方法小结

    Go语言读取文件的方法小结

    写程序时经常需要从一个文件读取数据,然后输出到另一个文件,这篇文章主要为大家详细介绍了Go语言读取文件的几种方法,希望对大家有所帮助
    2024-01-01
  • 举例详解Go语言中os库的常用函数用法

    举例详解Go语言中os库的常用函数用法

    这篇文章主要介绍了Go语言中os库的常用函数用法,os函数的使用是Go语言入门学习中的基础知识,需要的朋友可以参考下
    2015-10-10
  • 7分钟读懂Go的临时对象池pool以及其应用场景

    7分钟读懂Go的临时对象池pool以及其应用场景

    这篇文章主要给大家介绍了关于如何通过7分钟读懂Go的临时对象池pool以及其应用场景的相关资料,文中通过示例代码介绍的非常详细,对大家学习或使用Go具有一定的参考学习价值,需要的朋友们下面来一起看看吧
    2018-11-11
  • Go+Redis缓存设计与优化实现

    Go+Redis缓存设计与优化实现

    本文主要介绍了Go+Redis缓存设计与优化实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2025-02-02
  • 用Go+Vue.js快速搭建一个Web应用(初级demo)

    用Go+Vue.js快速搭建一个Web应用(初级demo)

    这篇文章主要介绍了用Go+Vue.js快速搭建一个Web应用(初级demo),本文给大家介绍的非常详细,具有参考借鉴价值,需要的朋友参考下吧
    2017-11-11
  • 用gin开发的golang项目三种开发模式方式

    用gin开发的golang项目三种开发模式方式

    这篇文章主要介绍了用gin开发的golang项目三种开发模式方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-01-01
  • golang context接口类型方法介绍

    golang context接口类型方法介绍

    这篇文章主要为大家介绍了golang context接口类型方法详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-09-09
  • idea搭建go环境实现go语言开发

    idea搭建go环境实现go语言开发

    这篇文章主要给大家介绍了关于idea搭建go环境实现go语言开发的相关资料,文中通过图文介绍以及代码介绍的非常详细,对大家学习或者使用go具有一定的参考借鉴价值,需要的朋友可以参考下
    2024-01-01
  • 详解在Go语言单元测试中如何解决Redis存储依赖问题

    详解在Go语言单元测试中如何解决Redis存储依赖问题

    在编写单元测试时,除了 MySQL 这个外部存储依赖,Redis 应该是另一个最为常见的外部存储依赖了,本文就来讲解下如何解决 Redis 外部依赖,文章通过代码示例介绍的非常详细,需要的朋友可以参考下
    2023-08-08

最新评论