佳木斯湛栽影视文化发展公司

主頁(yè) > 知識(shí)庫(kù) > go并發(fā)實(shí)現(xiàn)素?cái)?shù)篩的代碼

go并發(fā)實(shí)現(xiàn)素?cái)?shù)篩的代碼

熱門(mén)標(biāo)簽:服務(wù)外包 鐵路電話(huà)系統(tǒng) 百度競(jìng)價(jià)排名 呼叫中心市場(chǎng)需求 AI電銷(xiāo) 網(wǎng)站排名優(yōu)化 Linux服務(wù)器 地方門(mén)戶(hù)網(wǎng)站

先貼代碼

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;i10;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)

您可能感興趣的文章:
  • Golang 并發(fā)以及通道的使用方式
  • golang 如何替換掉字符串里面的換行符\n
  • spring boot集成mongodb的增刪改查的示例代碼
  • Django學(xué)習(xí)筆記之View操作指南
  • golang 中的 nil的場(chǎng)景分析
  • 完美解決go Fscanf 在讀取文件時(shí)出現(xiàn)的問(wèn)題

標(biāo)簽:黃山 崇左 湖南 仙桃 蘭州 衡水 湘潭 銅川

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《go并發(fā)實(shí)現(xiàn)素?cái)?shù)篩的代碼》,本文關(guān)鍵詞  ;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。
  • 相關(guān)文章
  • 收縮
    • 微信客服
    • 微信二維碼
    • 電話(huà)咨詢(xún)

    • 400-1100-266
    江阴市| 通道| 当涂县| 金川县| 古蔺县| 大英县| 东山县| 黄骅市| 大埔县| 桦南县| 类乌齐县| 成武县| 张掖市| 南昌县| 宾川县| 广丰县| 兴业县| 兴隆县| 紫阳县| 昭苏县| 姜堰市| 阿拉善左旗| 鄂温| 高清| 田阳县| 康定县| 鹰潭市| 拜泉县| 鄂尔多斯市| 常德市| 弋阳县| 孝义市| 克山县| 财经| 夏津县| 博爱县| 北流市| 青龙| 广平县| 石楼县| 邵武市|