go并發如何實現素數篩

這篇文章主要介紹了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, " ")
		ch2 := make(chan int)
		go filter(ch, ch2, prime)
		ch = ch2
	}
}

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

接下來我們看張圖

這就是上面算法的流程圖，我剛開始很難的理解是：為什么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=ch2)

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