Go語(yǔ)言并發(fā)之美：解釋其中內(nèi)核、外延

Flash版LOGO語(yǔ)言V9.8 免費(fèi)簡(jiǎn)體中文版

• 類型：編程工具大�。�3.2M語(yǔ)言：中文 評(píng)分：6.3
• 標(biāo)簽：

立即下載

ChainFilter技術(shù)

      前面提到了Future技術(shù)首尾相連，可以形成一個(gè)并發(fā)的pipe filter。這種方式可以做很多事情，如果每個(gè)Filter都由同一個(gè)函數(shù)組成，還可以有一種簡(jiǎn)單的辦法把他們連起來(lái)。

由于每個(gè)Filter協(xié)程都可以并發(fā)運(yùn)行，這樣的結(jié)構(gòu)非常有利于多核環(huán)境。下面是一個(gè)例子，用這種模式來(lái)產(chǎn)生素?cái)?shù)。

// Aconcurrent prime sieve

packagemain

// Sendthe sequence 2, 3, 4, ... to channel 'ch'.

funcGenerate(ch chan<- int) {

         for i := 2; ; i++ {

                  ch<- i // Send 'i' to channel 'ch'.

         }

}

// Copythe values from channel 'in' to channel 'out',

//removing those divisible by 'prime'.

funcFilter(in <-chan int, out chan<- int, prime int) {

         for {

                   i := <-in // Receive valuefrom 'in'.

                   if i%prime != 0 {

                            out <- i // Send'i' to 'out'.

                   }

         }

}

// Theprime sieve: Daisy-chain Filter processes.

funcmain() {

         ch := make(chan int) // Create a newchannel.

         go Generate(ch)      // Launch Generate goroutine.

         for i := 0; i < 10; i++ {

                   prime := <-ch

                   print(prime, "\n")

                   ch1 := make(chan int)

                   go Filter(ch, ch1, prime)

                   ch = ch1

         }

}

        上面的程序創(chuàng)建了10個(gè)Filter，每個(gè)分別過(guò)濾一個(gè)素?cái)?shù)，所以可以輸出前10個(gè)素?cái)?shù)。   

        Chain-Filter通過(guò)簡(jiǎn)單的代碼創(chuàng)建并發(fā)的過(guò)濾器鏈。這種辦法還有一個(gè)好處，就是每個(gè)通道只有兩個(gè)協(xié)程會(huì)訪問(wèn)，就不會(huì)有激烈的競(jìng)爭(zhēng)，性能會(huì)比較好。