Go使用協(xié)程交替打印字符
需求： 模擬兩個協(xié)程，分別循環(huán)打印字母A和B。
分析： 要實現(xiàn)兩個協(xié)程之間的交替協(xié)作，就必須用到channel通信機制，而channel正好是同步阻塞的。
半開方式
首先我們用一個channel變量來控制兩個goroutine的交替打?。?/p>
func main() {
exit := make(chan bool)
ch1 := make(chan int)
go func() {
for i := 1; i <= 10; i++ {
ch1 <- 0 //生產(chǎn)
fmt.Println("A",i)
}
exit <- true
}()
go func() {
for i := 1; i <= 10; i++ {
<-ch1 //消費
fmt.Println("B",i)
}
}()
<-exit
}
結果發(fā)現(xiàn)打印出了ABBAABBA...的效果。
也就是我們控制了開始的次序，但沒有控制結束的次序，發(fā)生了并發(fā)不安全的情況。
其實半開模式也可以用于某些場景下，如: 兩個goroutine，在條件控制下，交替打印奇偶數(shù)：
func main() {
exit := make(chan bool)
ch1 := make(chan int)
go func() {
for i := 1; i <= 10; i++ {
ch1 <- 0
if i%2 == 0 {
fmt.Println("A", i)
}
}
exit <- true
}()
go func() {
for i := 1; i <= 10; i++ {
<-ch1
if i%2 == 1 {
fmt.Println("B", i)
}
}
}()
<-exit
}
封閉方式
接下來我們使用兩個channel變量來模擬goroutine循環(huán)體的互斥問題。
func main() {
exit := make(chan bool)
ch1, ch2 := make(chan bool), make(chan bool)
go func() {
for i := 1; i <= 10; i++ {
ch1 <- true
fmt.Println("A", i)
//在ch1和ch2之間是阻塞獨占的
<-ch2
}
exit <- true
}()
go func() {
for i := 1; i <= 10; i++ {
<-ch1
fmt.Println("B", i)
ch2 <- true
}
}()
<-exit
}
我們在循環(huán)體首尾都使用了阻塞獨占模式，兩個chan交替釋放控制權，達到了安全的協(xié)程交互控制。
再看看下面的Demo，同樣的原理：
func main(){
ch1 :=make(chan int)
ch2 :=make(chan string)
str :=[5]string{"a","b","c","d","e"}
go func() {
for i:=0;i<5;i++{
ch1<-i
fmt.Print(i+1)
<-ch2
}
}()
for _,v :=range str{
<-ch1
fmt.Print(v)
ch2<-v
}
}
緩沖模式
緩沖模式和封閉模式相似，只是封閉模式中，兩個goroutine有明確的首尾角色。而緩沖模式的第一生產(chǎn)者交給了主協(xié)程，兩個goroutine結構一樣，輪式交換角色。
func main() {
exit := make(chan bool)
ch1, ch2 := make(chan bool,1), make(chan bool)
ch1 <- true //生產(chǎn)(選擇一個啟動項)
go func() {
for i := 1; i <= 10; i++ {
if ok := <-ch1; ok { //消費
fmt.Println("A", 2*i-1)
ch2 <- true //生產(chǎn)
}
}
}()
go func() {
defer func() { close(exit) }()
for i := 1; i <= 10; i++ {
if ok := <-ch2; ok { //消費
fmt.Println("B", 2*i)
ch1 <- true //生產(chǎn)
}
}
}()
<-exit
}
結論：
Channel的本質就是同步式的生產(chǎn)消費模式
補充：go 讓N個協(xié)程交替打印1-100
今天遇到一道面試題，開啟N個協(xié)程，并交替打印1-100如給定N=3則輸出:
goroutine0: 0
goroutine1: 1
goroutine2: 2
goroutine0: 3
goroutine1: 4
面試時沒答案，雖過后研究參考了一些網(wǎng)上方法，并記錄下來，先上代碼
func print() {
chanNum := 3 // chan 數(shù)量
chanQueue := make([]chan int, chanNum) // 創(chuàng)建chan Slice
var result = 0 // 值
exitChan := make(chan bool) // 退出標識
for i := 0; i < chanNum; i++ {
// 創(chuàng)建chan
chanQueue[i] = make(chan int)
if i == chanNum-1 {
// 給最后一個chan寫一條數(shù)據(jù)，為了第一次輸出從第1個chan輸出
go func(i int) {
chanQueue[i] <- 1
}(i)
}
}
for i := 0; i < chanNum; i++ {
var lastChan chan int // 上一個goroutine 結束才能輸出 控制輸出順序
var curChan chan int // 當前阻塞輸出的goroutine
if i == 0 {
lastChan = chanQueue[chanNum-1]
} else {
lastChan = chanQueue[i-1]
}
curChan = chanQueue[i]
go func(i int, lastChan, curChan chan int) {
for {
if result > 100 {
// 超過100就退出
exitChan <- true
}
// 一直阻塞到上一個輸出完，控制順序
<-lastChan
fmt.Printf("thread%d: %d \n", i, result)
result = result + 1
// 當前goroutine已輸出
curChan <- 1
}
}(i, lastChan, curChan)
}
<-exitChan
fmt.Println("done")
}
1、第一個for循環(huán)創(chuàng)建chan
2、第二個for循環(huán)里的lastChan意思是，當前chan如果要打印數(shù)據(jù)，就必須得上一個chan打印完后才能打印。
這里假設N=2，chan索引為0,1，當索引1要輸出,就阻塞到索引0的chan有數(shù)據(jù)為止，當自己打印完后往自己的chan中發(fā)送一個1,方便給依賴自己的chan 解除阻塞。
這里有個特殊的地方，當索引為0時，他的依賴索引chan就為chanQueue的長度-1，如果沒有在創(chuàng)建Chan中的時候沒有下面這一串代碼就會造成死鎖
if i == chanNum-1 {
// 給最后一個chan寫一條數(shù)據(jù)，為了第一次輸出從第1個chan輸出
go func(i int) {
chanQueue[i] <- 1
}(i)
}
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方，望不吝賜教。
相關文章
Golang應用執(zhí)行Shell命令實戰(zhàn)
本文主要介紹了Golang應用執(zhí)行Shell命令實戰(zhàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-03-03
Golang?實現(xiàn)Redis?協(xié)議解析器的解決方案
這篇文章主要介紹了Golang???實現(xiàn)?Redis?協(xié)議解析器,本文將分別介紹Redis 通信協(xié)議 以及 協(xié)議解析器 的實現(xiàn)，若您對協(xié)議有所了解可以直接閱讀協(xié)議解析器部分，需要的朋友可以參考下2022-10-10
這篇文章主要為大家介紹了Go?gRPC服務雙向流式RPC教程示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-06-06
這篇文章主要為大家介紹了golang構建工具Makefile的使用詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-07-07
在?Golang?語言開發(fā)中，我們經(jīng)常會使用結構體類型，如果我們使用的結構體類型的變量包含指針類型的字段，我們在記錄日志的時候，指針類型的字段的值是指針地址，將會給我們?debug?代碼造成不便2022-10-10
golang 數(shù)組去重,利用map的實現(xiàn)
這篇文章主要介紹了golang 數(shù)組去重,利用map的實現(xiàn)方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-04-04
LRU是一種常見的緩存淘汰策略,用于管理緩存中的數(shù)據(jù),本文主要介紹了go語言實現(xiàn)LRU緩存的示例代碼,具有一定的參考價值,感興趣的可以了解一下2024-02-02
這篇文章主要為大家介紹了通過java講解go同步原語Phaser和Barrier區(qū)別,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-12-12
Go語言提供了強大的測試工具，下面這篇文章主要給大家介紹了關于Golang單元測試和性能測試的相關資料，文中通過示例代碼給大家詳細介紹了單元測試和性能測試的相關內容，需要的朋友可以參考借鑒，下面來一起看看吧。2017-08-08
這篇文章主要介紹了go?get?如何使用私有庫,本文會明確指出Git?、golang的配置項，附送TortoiseGit?+?Git混合配置，需要的朋友可以參考下2022-09-09