async

Documentation

Index

• Variables
• func End(asyncRet chan Ret)
• func EndT[T any](asyncRet chan RetT[T])
• func MakeAsyncRet() chan Ret
• func MakeAsyncRetT[T any]() chan RetT[T]
• func Return(asyncRet chan Ret, ret Ret) chan Ret
• func ReturnT[T any](asyncRet chan RetT[T], ret RetT[T]) chan RetT[T]
• func Yield(ctx context.Context, asyncRet chan Ret, ret Ret) bool
• func YieldT[T any](ctx context.Context, asyncRet chan RetT[T], ret RetT[T]) bool
• type AsyncRet
• type AsyncRetT
  • func (asyncRet AsyncRetT[T]) Wait(ctx context.Context) RetT[T]
• type Callee
• type Caller
• type Ret
  • func MakeRet(val any, err error) Ret
• type RetT
  • func AsRetT[T any](ret Ret) (RetT[T], bool)
  • func CastRetT[T any](ret Ret) RetT[T]
  • func MakeRetT[T any](val T, err error) RetT[T]
  • func (ret RetT[T]) OK() bool
  • func (ret RetT[T]) String() string

Variables

var (
	ErrAsyncRetClosed = fmt.Errorf("%w: async result closed", exception.ErrCore)
)

var (
	VoidRet = MakeRet(nil, nil) // 空返回值
)

Functions

func End

func End(asyncRet chan Ret)

End 结束产出异步调用结果

func EndT

func EndT[T any](asyncRet chan RetT[T])

EndT 结束产出异步调用结果

func MakeAsyncRet

func MakeAsyncRet() chan Ret

MakeAsyncRet 创建异步调用结果

func MakeAsyncRetT

func MakeAsyncRetT[T any]() chan RetT[T]

MakeAsyncRetT 创建异步调用结果

func Return

func Return(asyncRet chan Ret, ret Ret) chan Ret

Return 返回异步调用结果

func ReturnT

func ReturnT[T any](asyncRet chan RetT[T], ret RetT[T]) chan RetT[T]

ReturnT 返回异步调用结果

func Yield

func Yield(ctx context.Context, asyncRet chan Ret, ret Ret) bool

Yield 产出异步调用结果

func YieldT

func YieldT[T any](ctx context.Context, asyncRet chan RetT[T], ret RetT[T]) bool

YieldT 产出异步调用结果

Types

type AsyncRet

type AsyncRet = AsyncRetT[any]

AsyncRet 异步调用结果

type AsyncRetT

type AsyncRetT[T any] <-chan RetT[T]

AsyncRetT 异步调用结果

func (AsyncRetT[T]) Wait

func (asyncRet AsyncRetT[T]) Wait(ctx context.Context) RetT[T]

Wait 等待异步调用结果

type Callee

type Callee interface {
	// PushCallAsync 将调用函数压入接受者的任务处理流水线，返回AsyncRet。
	PushCallAsync(fun generic.FuncVar0[any, Ret], args ...any) AsyncRet
	// PushCallDelegateAsync 将调用委托压入接受者的任务处理流水线，返回AsyncRet。
	PushCallDelegateAsync(fun generic.DelegateVar0[any, Ret], args ...any) AsyncRet
	// PushCallVoidAsync 将调用函数压入接受者的任务处理流水线，返回AsyncRet。
	PushCallVoidAsync(fun generic.ActionVar0[any], args ...any) AsyncRet
	// PushCallDelegateVoidAsync 将调用委托压入接受者的任务处理流水线，返回AsyncRet。
	PushCallDelegateVoidAsync(fun generic.DelegateVoidVar0[any], args ...any) AsyncRet
}

Callee 异步调用接受者

type Caller

type Caller interface {
	// CallAsync 异步调用函数，有返回值。不会阻塞当前线程，会返回AsyncRet。
	//
	//	注意：
	//	- 代码片段中的线程安全问题，如临界区访问、线程死锁等。
	//  - 调用过程中的panic信息，均会转换为error返回。
	CallAsync(fun generic.FuncVar0[any, Ret], args ...any) AsyncRet

	// CallDelegateAsync 异步调用委托，有返回值。不会阻塞当前线程，会返回AsyncRet。
	//
	//	注意：
	//	- 代码片段中的线程安全问题，如临界区访问、线程死锁等。
	//  - 调用过程中的panic信息，均会转换为error返回。
	CallDelegateAsync(fun generic.DelegateVar0[any, Ret], args ...any) AsyncRet

	// CallVoidAsync 异步调用函数，无返回值。在运行时中。不会阻塞当前线程，会返回AsyncRet。
	//
	//	注意：
	//	- 代码片段中的线程安全问题，如临界区访问、线程死锁等。
	//  - 调用过程中的panic信息，均会转换为error返回。
	CallVoidAsync(fun generic.ActionVar0[any], args ...any) AsyncRet

	// CallDelegateVoidAsync 异步调用委托，无返回值。在运行时中。不会阻塞当前线程，会返回AsyncRet。
	//
	//	注意：
	//	- 代码片段中的线程安全问题，如临界区访问、线程死锁等。
	//  - 调用过程中的panic信息，均会转换为error返回。
	CallDelegateVoidAsync(fun generic.DelegateVoidVar0[any], args ...any) AsyncRet
}

Caller 异步调用发起者

type Ret

type Ret = RetT[any]

Ret 调用结果

func MakeRet

func MakeRet(val any, err error) Ret

MakeRet 创建调用结果

type RetT

type RetT[T any] struct {
	Value T     // 返回值
	Error error // error
}

RetT 调用结果

func AsRetT

func AsRetT[T any](ret Ret) (RetT[T], bool)

AsRetT 转换

func CastRetT

func CastRetT[T any](ret Ret) RetT[T]

CastRetT 转换

func MakeRetT

func MakeRetT[T any](val T, err error) RetT[T]

MakeRetT 创建调用结果

func (RetT[T]) OK

func (ret RetT[T]) OK() bool

OK 是否成功

func (RetT[T]) String

func (ret RetT[T]) String() string

String implements fmt.Stringer