我有一個(gè)對(duì) HTTP 服務(wù)器執(zhí)行查詢的程序，每個(gè)請(qǐng)求都有一個(gè) goroutine。我很快發(fā)現(xiàn)這對(duì)于 MacOS 來說太多了，因?yàn)槲募枋龇拗茷?250。我想知道是否可以限制 goroutine 的數(shù)量，或者在有可用的 goroutine 之前阻塞，而不是失敗。也許是一個(gè)有 250 個(gè) goroutines 的工作池，并將其余的請(qǐng)求排隊(duì)？你怎么認(rèn)為
1 回答
元芳怎么了
TA貢獻(xiàn)1798條經(jīng)驗(yàn) 獲得超7個(gè)贊
package main
import "fmt"
const ROUTINE_LIMIT = 250
func main() {
channelCounter := make(chan bool, ROUTINE_LIMIT)
for {
select {
//will add till 250 after that it will block
case channelCounter <- true:
fmt.Println("added channel")
go startRoutine(channelCounter)
}
}
}
func startRoutine(channelCounter chan bool) {
/*
do your stuff
*/
//free the channel
<-channelCounter
}
您可以使用通道限制您的 goruotine 計(jì)數(shù)。一個(gè)用于記錄運(yùn)行的 goroutine 數(shù)量的通道。一旦工作完成，您可以讀取通道值以減少計(jì)數(shù)。
上面的程序就像一個(gè)粗略的示例代碼..（我認(rèn)為它涵蓋了一般想法）
- 1 回答
- 0 關(guān)注
- 90 瀏覽
添加回答
舉報(bào)
0/150
提交
取消