ctx

Documentation

Index

• Variables
• func CallCancel(ctx context.Context) error
• func CarryCancel(ctx context.Context, cancelFunc context.CancelFunc) context.Context
• func Done(ctx context.Context) bool
• func GenDLCtx(t time.Time) context.Context
• func GenTOCtx(t time.Duration) context.Context
• func PutVal[T any](ctx context.Context, key *Value[T], v T)
• func WaitCtx(ctx context.Context) (dctx context.Context, done func())
• func WithWait(sctx context.Context, planNum int32, to ...time.Duration) (dctx context.Context, done func() error)
• type Ctx
• type Value
  • func (t *Value[T]) Get() T
  • func (t *Value[T]) LinkCtx(ctx context.Context) context.Context
  • func (t *Value[T]) Set(data T)

Variables

var (
	ErrWaitTo      = errors.New("ErrWaitTo")
	ErrNothingWait = errors.New("ErrNothingWait")
)

var (
	ErrNotCarryYet = errors.New("ErrNotCarryYet")
)

Functions

func CallCancel

func CallCancel(ctx context.Context) error

func CarryCancel

func CarryCancel(ctx context.Context, cancelFunc context.CancelFunc) context.Context

func Done

func Done(ctx context.Context) bool

func GenDLCtx

func GenDLCtx(t time.Time) context.Context

func GenTOCtx

func GenTOCtx(t time.Duration) context.Context

func PutVal

func PutVal[T any](ctx context.Context, key *Value[T], v T)

func WaitCtx

func WaitCtx(ctx context.Context) (dctx context.Context, done func())

go func(){
	ctx1, done1 := WaitCtx(mainCtx)
	defer done1()
	do something..
	<-ctx1.Done() // wait mainDone call
}()

func WithWait

func WithWait(sctx context.Context, planNum int32, to ...time.Duration) (dctx context.Context, done func() error)

planNum 可以为0 表示无法预知的调用次数，如果在mainDone调用前没有Wait、WithWait时，mainDone将返回ErrNothingWait

	mainCtx, mainDone := WithWait(ctx, 0, time.Second)
	defer mainDone()// wait done1 or after one second

	go func(){
		ctx1, done1 := WaitCtx(mainCtx)
		defer done1()
		do something..
 		<-ctx1.Done() // wait mainDone call
	}()

Types

type Ctx

type Ctx struct {
	Ctx context.Context
	// contains filtered or unexported fields
}

type Value

type Value[T any] struct {
	// contains filtered or unexported fields
}

errCtx := pctx.Value[error]{}

cancelC = errCtx.LinkCtx(cancelC)

pctx.PutVal(cancelC, &errCtx, fmt.Errorf("%vs未接收到有效数据", readTO))

err := errCtx.Get()

func (*Value[T]) Get

func (t *Value[T]) Get() T

func (*Value[T]) LinkCtx

func (t *Value[T]) LinkCtx(ctx context.Context) context.Context

func (*Value[T]) Set

func (t *Value[T]) Set(data T)