Golang併發模式基礎

最基本的模式：

for
}

每個condition都有機會被執行一次，內部使用了偽隨機的策略。如果case條件全部阻塞，那麼執行default的條件。

golang的goroutine無法被gc，只能等待goroutine自動執行結束。因此，如果某些情況下，如果goroutine阻塞了，則只能等待整個程式結束才能**。雖然goroutine記憶體消耗少，但是也不能一直申請。

基本的解決思路是傳入乙個終止chan，**如下：

package main
import
("fmt"
"math/rand"
"time"
)func
main()
)<-
chan
int}}(
)return randstream
}done :=
make
(chan
inte***ce
)    randstream :=
newrandstream
(done)
for i :=
0; i <
3; i++
close
(done)
time.
sleep(1
* time.second)
// 模擬其它工作
}

基本原則是：如果乙個goroutine負責建立goroutine，那麼它也可以保證停止建立的goroutine。

暫時不太理解，留作以後處理

package main
import
("fmt"
"math/rand"
"time"
)func
main()
)<-
chan
inte***ce
or =
func
(channels <-
chan
inte***ce
)<-
chan
inte***ce
ordone :=
make
(chan
inte***ce)go
func()
default
:select}}
()return ordone
}sig :=
func
(afert time.duration)
<-
chan
inte***ce)go
func()
()return c
}start := time.
now(
)<-or(
sig(
2*time.hour)
,sig(5
*time.minute)
,sig(1
*time.second)
,sig(1
*time.hour)
,sig(1
*time.minute)
)    fmt.
println
("done after %v"
, time.
since
(start)
)}

一般來說，併發程序應該把它們的錯誤傳送到程式的另乙個部分，錯誤中應該有程式的完整狀態資訊，以便可以做出更明確的決定。構建goroutine時，應該將錯誤視為一等公民，如果goroutine可能出現錯誤，那麼錯誤應該和返回值是一起的，通過相同的通訊線傳遞，就像常規的同步函式一樣。

Golang併發模式基礎

Golang併發程式設計基礎

Golang併發模式 channel高階使用

golang 閒談併發

Golang併發模式基礎

Golang併發程式設計基礎

Golang併發模式 channel高階使用

golang 閒談併發

相關推薦