在下面的示例中將上下文傳遞給 Wait() 函數的目的是什么？假設有一個限制器允許每秒 3 個請求。這是否意味著限制器不會成為共享資源，對于每個“進程”函數調用，它都會有自己的限制器實例和范圍，對嗎？如果不是這樣呢？我怎樣才能實現它？結構體type MyClass struct { limiter *rate.Limiter}func NewMyClass() (*MyClass, error) { return &MyClass{limiter: rate.NewLimiter(rate.Limit(3), 1)}, nil}func (m *MyClass) Process(ctx context.Context) error { err := m.limiter.Wait(ctx) if err != nil { return err } //more code}例子m, _ := s3Storage.NewMyClass() ctx1 := context.TODO() m.Process(ctx1) m.Process(ctx1) m.Process(ctx1) ctx2 := context.TODO() m.Process(ctx2)
2 回答
藍山帝景
TA貢獻1843條經驗 獲得超7個贊
首先，您需要了解rate.Limiter和context.Context類型的不同用途。允許您控制并發進程的Limiter執行速率。如果Context一個進程或一組進程繼續下去沒有意義（例如超時、丟失連接、用戶取消...），則允許終止該進程或一組進程。這些是簡化，因此請閱讀 doco 以獲取更多信息。
回答你的問題：
在示例中將上下文傳遞給 Wait() 函數的目的是什么？
沒有任何目的，因為TODO上下文永遠不會被取消。
這是否意味著限制器不會成為共享資源...？
不，它是共享的。你只有一個只有一個的MyClass實例Limiter。
如果沒有……我怎樣才能實現呢？
在每個 Process 函數調用上設置限制器是沒有意義的，因為一次調用永遠不會超過 3 的限制。
我認為您想要對 進行多組不同的限速調用Process，因此可能只需要 的多個實例MyClass，每個實例都有自己的Limiter。
我不確定你到底想做什么，但作為一個例子，速率限制器的典型用途是限制用戶或連接的進程數。類似地，上下文可能與附加到單個連接的所有進程相關聯，因此如果連接終止，一切都可以被整齊地清除。所以一個可能的場景是你有一個Connection有 aLimiter和 a的類型Context。
我希望這是有道理的。
- 2 回答
- 0 關注
- 104 瀏覽
添加回答
舉報
0/150
提交
取消