您好,登錄后才能下訂單哦!
今天小編給大家分享一下golang怎么去除context的deadline的相關(guān)知識(shí)點(diǎn),內(nèi)容詳細(xì),邏輯清晰,相信大部分人都還太了解這方面的知識(shí),所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來了解一下吧。
在使用 context 的時(shí)候遇到了開協(xié)程處理任務(wù)的情況,但是直接在協(xié)程里使用主線程的 context 會(huì)導(dǎo)致當(dāng)主線程返回時(shí)協(xié)程任務(wù)也會(huì)因?yàn)?context cancel 而失敗。
本文提供了兩種辦法可以取消掉 context 里的 timeout 和 deadline,再設(shè)置一個(gè)新的 timeout 上去。
最簡單的方案是通過創(chuàng)建一個(gè)新的 context 來解決這個(gè)問題。
func main() { ctx := context.WithValue(context.Background(), "trace", "123") ctx, cancel := context.WithTimeout(ctx, time.Second) defer cancel() go func(ctx context.Context) { newCtx := context.WithValue(context.Background(), "trace", ctx.Value("trace")) // do something with newCtx }(ctx) fmt.Println("main finished") }
但是這種方案有一個(gè)缺點(diǎn),當(dāng)生成一個(gè)新的 context 的時(shí)候,需要手動(dòng)把老 context 中的 value 手動(dòng)拿出來,再設(shè)置到新的里面去。 但是在很多情況下,這個(gè) context 是上游傳過來的,并不知道 value 里面有哪些具體的 key。或者里面的 value 過多,寫起來很麻煩。
通過看 context 的源碼,其實(shí)可以發(fā)現(xiàn) context 是一個(gè) interface,這就給了我們操作的空間。
type Context interface { Deadline() (deadline time.Time, ok bool) Done() <-chan struct{} Err() error Value(key any) any }
Context 是通過 Deadline() 這個(gè)函數(shù)控制整個(gè) ctx 是否超時(shí)了的。那么我們就可以通過重寫這個(gè)函數(shù)來規(guī)避超時(shí)。
// contextWithoutDeadline 偽造了一個(gè)沒有 deadline 的 context type contextWithoutDeadline struct { ctx context.Context } func (*contextWithoutDeadline) Deadline() (time.Time, bool) { return time.Time{}, false } func (*contextWithoutDeadline) Done() <-chan struct{} { return nil } func (*contextWithoutDeadline) Err() error { return nil } func (l *contextWithoutDeadline) Value(key interface{}) interface{} { return l.ctx.Value(key) } // DetachDeadline 從 context 剝離 deadline func DetachDeadline(ctx context.Context) context.Context { return &contextWithoutDeadline{ctx: ctx} } // SetNewTimeout 設(shè)置新的超時(shí)時(shí)間 func SetNewTimeout(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc) { return context.WithTimeout(DetachDeadline(ctx), timeout) }
可以通過 DetachDeadline() 方法來將原 ctx 的 deadline 取消掉,或者直接通過 SetNewTimeout 的方法設(shè)置一個(gè)新的超時(shí)時(shí)間上去。
演示
func main() { ctx, _ := context.WithTimeout(context.Background(), time.Duration(10)*time.Second) fmt.Println(ctx.Deadline()) newCtx := contextwarp.DetachDeadline(ctx) fmt.Println(newCtx.Deadline()) newCtx2, _ := contextwarp.SetNewTimeout(ctx, time.Duration(1)*time.Second) fmt.Println(newCtx2.Deadline()) }
符合預(yù)期。
以上就是“golang怎么去除context的deadline”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會(huì)為大家更新不同的知識(shí),如果還想學(xué)習(xí)更多的知識(shí),請關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。