在我的程序中，我有幾個 go-routines，它們本質上是在運行無窮無盡的進程。為什么？您可能會問，長話短說，這是我整個應用程序的目的，所以改變它是不可能的。我想讓用戶能夠停止單個 go-routine。我知道我可以使用 channel 來通知 go-routines 停止，但是可能有我有 10 個 go-routines 正在運行而我只想停止 1 個的情況。問題是 go-routines 的數量我想運行是動態的并且基于用戶輸入。對我來說，添加動態停止 go-routine 并允許單打停止的最佳方法是什么？
1 回答
汪汪一只貓
TA貢獻1898條經驗 獲得超8個贊
您需要設計一個地圖來管理上下文。
假設您已經知道上下文的用法。它可能看起來像：
ctx, cancel := context.WithCancel(ctx.TODO())
go func(ctx){
for {
select {
case <-ctx.Done():
return
default:
// job
}
}
}(ctx)
cancel()
好的，現在您可以將您的問題轉換為另一個問題，它可能稱為“如何管理許多 goroutine 的上下文”
type GoroutineManager struct{
m sync.Map
}
func (g *GoroutineManager) Add(cancel context.CancelFunc, key string)) {
g.m.Store(key, cancel)
}
func (g *GoroutineManager) KillGoroutine(key string) {
cancel, exist := g.m.Load(key)
if exist {
cancel()
}
}
好的，現在您可以像這樣管理您的 goroutine：
ctx, cancel := context.WithCancel(ctx.TODO())
manager.Add(cancel, "routine-job-1")
go func(ctx){
for {
select {
case <-ctx.Done():
return
default:
// job
}
}
}(ctx)
// kill it as your wish
manager.KillGoroutine("routine-job-1")
- 1 回答
- 0 關注
- 113 瀏覽
添加回答
舉報
0/150
提交
取消