go并發(fā)實(shí)現(xiàn)素?cái)?shù)篩的代碼
先貼代碼
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
}
}
第一次看這個(gè)素?cái)?shù)篩一臉懵逼，首先我們要理解不是并發(fā)的素?cái)?shù)篩，這個(gè)自行百度。
接下來(lái)我們看張圖
這就是上面算法的流程圖，我剛開(kāi)始很難的理解是：為什么generate產(chǎn)生的2，3，4，5....等數(shù)一定是先被2篩選呢？我們知道并發(fā)有個(gè)不確定性，我們?nèi)绻裧enerate函數(shù)當(dāng)作生產(chǎn)者，那么2，3，5，7這幾個(gè)素?cái)?shù)過(guò)濾器協(xié)程就是消費(fèi)者，根據(jù)一般的消費(fèi)者生產(chǎn)模型，生產(chǎn)者產(chǎn)生的2，3，4，5等各個(gè)數(shù)被消費(fèi)者使用的時(shí)候應(yīng)該是不確定性的。
這里的關(guān)鍵在于generate這個(gè)channel只連接了2這個(gè)協(xié)程，并沒(méi)有跟后面的協(xié)程相連接，而最秒的地方在于后面的每個(gè)協(xié)程的channel都只是與前后的協(xié)程相互通信的，這樣就達(dá)到了一個(gè)串聯(lián)的效果。
關(guān)鍵看代碼filter函數(shù)的參數(shù)in，out這兩個(gè)channel，in是上一個(gè)協(xié)程與當(dāng)前協(xié)程所建立的channel，out則是當(dāng)前協(xié)程與下一個(gè)協(xié)程所建立的channel（因?yàn)榭磎ain里面ch=ch1)
相關(guān)文章
go語(yǔ)言實(shí)現(xiàn)簡(jiǎn)易比特幣系統(tǒng)錢包的原理解析
這篇文章主要介紹了go語(yǔ)言實(shí)現(xiàn)簡(jiǎn)易比特幣系統(tǒng)錢包的原理解析,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-04-04
channel（通道），顧名思義，是一種通道，一種用于并發(fā)環(huán)境中數(shù)據(jù)傳遞的通道。channel是golang中標(biāo)志性的概念之一，很好很強(qiáng)大！本文將從源碼帶大家了解一下channel的使用，希望對(duì)大家有所幫助2022-12-12
quicktemplate快速、功能強(qiáng)大、易于使用的Go模板引擎。比html/模板快20倍，本文我們就詳細(xì)的介紹一下quicktemplate的具體使用，感興趣的可以了解一下2021-07-07
Go 自定義package包設(shè)置與導(dǎo)入操作
這篇文章主要介紹了Go 自定義package包設(shè)置與導(dǎo)入操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-05-05
一文詳解Go語(yǔ)言中的Option設(shè)計(jì)模式
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言中Option設(shè)計(jì)模式的相關(guān)知識(shí)，文中的示例代碼講解詳細(xì)，具有一定的學(xué)習(xí)價(jià)值，感興趣的可以了解一下2023-05-05
這篇文章主要為大家介紹了一文初探?Goroutine?與?channel基本用法詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-02-02
Go語(yǔ)言實(shí)現(xiàn)Sm2加解密的示例代碼
本文主要介紹了Go語(yǔ)言實(shí)現(xiàn)Sm2加解密的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-03-03
Go?Singleflight導(dǎo)致死鎖問(wèn)題解決分析
這篇文章主要為大家介紹了Go?Singleflight導(dǎo)致死鎖問(wèn)題解決分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-09-09
十個(gè)Golang開(kāi)發(fā)中應(yīng)該避免的錯(cuò)誤總結(jié)
Go是一種靜態(tài)類型的、并發(fā)的、垃圾收集的編程語(yǔ)言，由谷歌開(kāi)發(fā)。開(kāi)發(fā)人員在編寫Go代碼時(shí)總會(huì)有一些常見(jiàn)的錯(cuò)誤，下面是Go語(yǔ)言中需要避免的十大壞錯(cuò)誤，希望對(duì)大家有所幫助2023-03-03
golang框架中跨服務(wù)的最佳通信協(xié)議和工具
在 go 框架中實(shí)現(xiàn)跨服務(wù)通信的最佳實(shí)踐包括使用 grpc（適用于低延遲高吞吐量）、http 客戶端（適用于 restful api）和消息隊(duì)列（適用于異步解耦通信）,在選擇通信方式時(shí),應(yīng)考慮服務(wù)交互模式、性能要求和部署環(huán)境等因素2024-06-06