go并發(fā)如何實現(xiàn)素數(shù)篩

這篇文章主要介紹了go并發(fā)如何實現(xiàn)素數(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, " ")
		ch2 := make(chan int)
		go filter(ch, ch2, prime)
		ch = ch2
	}
}

第一次看這個素數(shù)篩一臉懵逼，首先我們要理解不是并發(fā)的素數(shù)篩，這個自行百度。

接下來我們看張圖

這就是上面算法的流程圖，我剛開始很難的理解是：為什么generate產(chǎn)生的2，3，4，5....等數(shù)一定是先被2篩選呢？我們知道并發(fā)有個不確定性，我們?nèi)绻裧enerate函數(shù)當作生產(chǎn)者，那么2，3，5，7這幾個素數(shù)過濾器協(xié)程就是消費者，根據(jù)一般的消費者生產(chǎn)模型，生產(chǎn)者產(chǎn)生的2，3，4，5等各個數(shù)被消費者使用的時候應(yīng)該是不確定性的。

這里的關(guān)鍵在于generate這個channel只連接了2這個協(xié)程，并沒有跟后面的協(xié)程相連接，而最秒的地方在于后面的每個協(xié)程的channel都只是與前后的協(xié)程相互通信的，這樣就達到了一個串聯(lián)的效果。

關(guān)鍵看代碼filter函數(shù)的參數(shù)in，out這兩個channel，in是上一個協(xié)程與當前協(xié)程所建立的channel，out則是當前協(xié)程與下一個協(xié)程所建立的channel（因為看main里面ch=ch2)

感謝你能夠認真閱讀完這篇文章，希望小編分享的“go并發(fā)如何實現(xiàn)素數(shù)篩”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識等著你來學(xué)習!