没有取消传播的上下文
Context without cancel propagation
我如何创建一个 Go 上下文的副本(如果你愿意的话,也可以是克隆),它包含存储在原始文件中的所有值,但不会在原始文件被取消时被取消?
对我来说这确实是一个有效的用例。假设我有一个 http 请求,它的上下文在响应返回给客户端后被取消,我需要在这个请求的末尾 运行 在一个单独的 goroutine 中执行一个异步任务,该 goroutine 很可能会超过父上下文。
func Handler(ctx context.Context) (interface{}, error) {
result := doStuff(ctx)
newContext := howDoICloneYou(ctx)
go func() {
doSomethingElse(newContext)
}()
return result
}
任何人都可以建议应该如何完成吗?
当然我可以跟踪所有可能放入上下文的值,创建一个新的背景 ctx 然后遍历每个可能的值并复制...但这看起来很乏味且难以管理在大型代码库中。
Can anyone advice how this is supposed to be done?
是的。别这样。
如果您需要不同的上下文,例如然后为您的异步后台任务创建一个 new 上下文。您的传入上下文和您的后台任务之一无关,因此您不得尝试重用传入上下文。
如果不相关的新上下文需要原始数据中的一些数据:复制您需要的内容并添加新内容。
由于 context.Context 是一个接口,您可以简单地创建自己的永不取消的实现:
import (
"context"
"time"
)
type noCancel struct {
ctx context.Context
}
func (c noCancel) Deadline() (time.Time, bool) { return time.Time{}, false }
func (c noCancel) Done() <-chan struct{} { return nil }
func (c noCancel) Err() error { return nil }
func (c noCancel) Value(key interface{}) interface{} { return c.ctx.Value(key) }
// WithoutCancel returns a context that is never canceled.
func WithoutCancel(ctx context.Context) context.Context {
return noCancel{ctx: ctx}
}
我如何创建一个 Go 上下文的副本(如果你愿意的话,也可以是克隆),它包含存储在原始文件中的所有值,但不会在原始文件被取消时被取消?
对我来说这确实是一个有效的用例。假设我有一个 http 请求,它的上下文在响应返回给客户端后被取消,我需要在这个请求的末尾 运行 在一个单独的 goroutine 中执行一个异步任务,该 goroutine 很可能会超过父上下文。
func Handler(ctx context.Context) (interface{}, error) {
result := doStuff(ctx)
newContext := howDoICloneYou(ctx)
go func() {
doSomethingElse(newContext)
}()
return result
}
任何人都可以建议应该如何完成吗?
当然我可以跟踪所有可能放入上下文的值,创建一个新的背景 ctx 然后遍历每个可能的值并复制...但这看起来很乏味且难以管理在大型代码库中。
Can anyone advice how this is supposed to be done?
是的。别这样。
如果您需要不同的上下文,例如然后为您的异步后台任务创建一个 new 上下文。您的传入上下文和您的后台任务之一无关,因此您不得尝试重用传入上下文。
如果不相关的新上下文需要原始数据中的一些数据:复制您需要的内容并添加新内容。
由于 context.Context 是一个接口,您可以简单地创建自己的永不取消的实现:
import (
"context"
"time"
)
type noCancel struct {
ctx context.Context
}
func (c noCancel) Deadline() (time.Time, bool) { return time.Time{}, false }
func (c noCancel) Done() <-chan struct{} { return nil }
func (c noCancel) Err() error { return nil }
func (c noCancel) Value(key interface{}) interface{} { return c.ctx.Value(key) }
// WithoutCancel returns a context that is never canceled.
func WithoutCancel(ctx context.Context) context.Context {
return noCancel{ctx: ctx}
}