async

Documentation

Index

• Variables
• func MakeAsyncRetT[T any]() chan RetT[T]
• type AsyncRet
• type AsyncRetT
  • func (asyncRet AsyncRetT[T]) Wait(ctx context.Context) RetT[T]
• type Callee
• type Caller
• type 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 (
	MakeRet = MakeRetT[any]
	VoidRet = MakeRet(nil, nil)
)

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

var (
	MakeAsyncRet = MakeAsyncRetT[any]
)

Functions

func MakeAsyncRetT

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

MakeAsyncRetT 创建异步调用结果

Types

type AsyncRet

type AsyncRet = AsyncRetT[any]

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 {
	// PushCall 将调用函数压入接受者的任务处理流水线，返回AsyncRet。
	PushCall(fun generic.FuncVar0[any, Ret], args ...any) AsyncRet
	// PushCallDelegate 将调用委托压入接受者的任务处理流水线，返回AsyncRet。
	PushCallDelegate(fun generic.DelegateFuncVar0[any, Ret], args ...any) AsyncRet
	// PushCallVoid 将调用函数压入接受者的任务处理流水线，返回AsyncRet。
	PushCallVoid(fun generic.ActionVar0[any], args ...any) AsyncRet
	// PushCallVoidDelegate 将调用委托压入接受者的任务处理流水线，返回AsyncRet。
	PushCallVoidDelegate(fun generic.DelegateActionVar0[any], args ...any) AsyncRet
}

Callee 异步调用接受者

type Caller

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

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

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

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

Caller 异步调用发起者

type Ret

type Ret = RetT[any]

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