Golang實現(xiàn)生產(chǎn)者和消費者

packagemain

銅梁ssl適用于網(wǎng)站、小程序/APP、API接口等需要進行數(shù)據(jù)傳輸應用場景，ssl證書未來市場廣闊！成為成都創(chuàng)新互聯(lián)公司的ssl證書銷售渠道，可以享受市場價格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：028-86922220（備注：SSL證書合作）期待與您的合作！

import(

"fmt"

"sync"

)

//實現(xiàn)一個生產(chǎn)者和消費者

/*生產(chǎn)者產(chǎn)生數(shù)據(jù)添加到通道里面，消費者消費數(shù)據(jù)從通道里面

不帶緩存實現(xiàn)

*/

funcmain(){

ch:=make(chanint)

varwgsync.WaitGroup

wg.Add(2)

goproducers(wg,ch)

goconsumer(wg,ch)

wg.Wait()

}

//生產(chǎn)者

funcproducers(wg*sync.WaitGroup,chchanint){

fori:=0;i10;i++{

fmt.Println("send:",i)

ch-i

}

close(ch)

wg.Done()

}

//消費者

funcconsumer(wg*sync.WaitGroup,chchanint){

forv:=rangech{

fmt.Println("recv:",v)

}

wg.Done()

}

???$?

go語言中channel的問題

第一個問題，打開文件應添加"|os.O_WRONLY"

file, err := os.OpenFile("data.dat",os.O_CREATE|os.O_APPEND|os.O_WRONLY,0777)

第二個問題，將Count方法中的 "ch-i"放到方法的最后一行就可以了。

因為一旦“ch-i"執(zhí)行了，main方法中的 "-ch"就會執(zhí)行通過當所有的"-ch"執(zhí)行完后程序就結(jié)束了。但這時Count的線程方法還來不及執(zhí)行完（打開文件的速度相對較慢），所以僅僅執(zhí)行一次文件操作就結(jié)束了

Go語言中怎樣判斷數(shù)據(jù)類型

一般來說，我們不會直接使用ASCII碼來處理，因為這樣不夠直觀。比如你說的判定輸入是否是字母，是否是數(shù)字，那么有個比較直觀的方法來處理。如果你看過ASCII碼表，那么你就知道字數(shù)和字母在ASCII碼表中都是連續(xù)的，所以這個就比較好解決了。

判定字符ch是否是數(shù)字：

if(ch='0' ch='9')

判定字符ch是否是字母：

if(ch='a' ch='z' || ch='A' ch='Z')

當然，有已經(jīng)定義好的庫函數(shù)用來判定是否數(shù)字和字母，不要加加載頭文件ctype.h

判定字符ch是否是數(shù)字：

if(isalnum(ch));

判定字符ch是否是字母：

if(isalpha(ch));

這兩個函數(shù)都是判定成立，結(jié)果是true也就是1，判定不成立，結(jié)果是false，也就是0.

Go 語言 channel 的阻塞問題

Hello，大家好，又見面了！上一遍我們將 channel 相關(guān)基礎(chǔ)以及使用場景。這一篇，還需要再次進階理解channel 阻塞問題。以下創(chuàng)建一個chan類型為int，cap 為3。

channel 內(nèi)部其實是一個環(huán)形buf數(shù)據(jù)結(jié)構(gòu) ，是一種滑動窗口機制，當make完后，就分配在 Heap 上。

上面，向 chan 發(fā)送一條“hello”數(shù)據(jù)：

如果 G1 發(fā)送數(shù)據(jù)超過指定cap時，會出現(xiàn)什么情況？

看下面實例：

以上會出現(xiàn)什么，chan 緩沖區(qū)允許大小為1，如果再往chan仍數(shù)據(jù)，滿了就會被阻塞，那么是如何實現(xiàn)阻塞的呢？當 chan 滿時，會進入 gopark，此時 G1 進入一個 waiting 狀態(tài)，然后會創(chuàng)建一個 sudog 對象，其實就sendq隊列，把 200放進去。等 buf 不滿的時候，再喚醒放入buf里面。

通過如下源碼，你會更加清晰：

上面，從 chan 獲取數(shù)據(jù)：

Go 語言核心思想：“Do not communicate by sharing memory; instead, share memory by communicating.” 你可以看看這本書名叫：Effective Go

如果接收者，接收一個空對象，也會發(fā)生什么情況？

代碼示例 ：

也會報錯如下：

上面，從 chan 取出數(shù)據(jù)，可是沒有數(shù)據(jù)了。此時，它會把 接收者 G2 阻塞掉，也是和G1發(fā)送者一樣，也會執(zhí)行 gopark 將狀態(tài)改為 waiting，不一樣的點就是。

正常情況下，接收者G2作為取出數(shù)據(jù)是去 buf 讀取數(shù)據(jù)的，但現(xiàn)在，buf 為空了，此時，接收者G2會將sudog導出來，因為現(xiàn)在G2已經(jīng)被阻塞了嘛，會把G2給G，然后將 t := -ch 中變量 t 是在棧上的地址，放進去 elem ，也就是說，只存它的地址指針在sudog里面。

最后， ch - 200 當G1往 chan 添加200這個數(shù)據(jù)，正常情況是將數(shù)據(jù)添加到buf里面，然后喚醒 G2 是吧，而現(xiàn)在是將 G1 的添加200數(shù)據(jù)直接干到剛才G2阻塞的t這里變量里面。

你會認為，這樣真的可以嗎？想一想，G2 本來就是已經(jīng)阻塞了，然后我們直接這么干肯定沒有什么毛病，而且效率提高了，不需要再次放入buf再取出，這個過程也是需要時間。不然，不得往chan添加數(shù)據(jù)需要加鎖、拷貝、解鎖一序列操作，那肯定就慢了，我想Go語言是為了高效及內(nèi)存使用率的考慮這樣設計的。（注意，一般都是在runtime里面完成，不然會出現(xiàn)象安全問題。）

總結(jié) ：

chan 類型的特點：chan 如果為空，receiver 接收數(shù)據(jù)的時候就會阻塞等待，直到 chan 被關(guān)閉或者有新的數(shù)據(jù)到來。有這種個機制，就可以實現(xiàn) wait/notify 的設計模式。

相關(guān)面試題：

本文名稱：go語言中ch用法 go語言%v
URL地址：http://www.chinadenli.net/article6/dosgoog.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供企業(yè)建站、網(wǎng)站設計公司、網(wǎng)站內(nèi)鏈、網(wǎng)站建設、商城網(wǎng)站、云服務器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)