await

package

v1.2.0 Latest Latest Go to latest Published: Apr 11, 2025 License: Apache-2.0 Imports: 5 Imported by: 5

Details

This section is empty.

View Source

var (
	ErrTimeout    = values.Errorf(0, "timeout")
	ErrServerBusy = values.Errorf(1, "server busy,try again later")
)

This section is empty.

type Await struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

func New(cap int, timeout time.Duration) *Await

func (this *Await) Call(handle Handle, args any) (any, error)

Call 同步调用handle并返回结果

func (this *Await) Sync(handle Handle, args any) *Message

Sync 异步执行，不关心执行结果也可以使用 Message.Done等待返回结果

func (this *Await) Try(handle Handle, args any) (any, error)

Try 如果通道已满，立即放弃执行

type Handle func(args any) (reply any, err error)

type Initialize struct {
	// contains filtered or unexported fields
}

Initialize 并发模式下初始化控制器

func NewInitialize() *Initialize

func (i *Initialize) Try(f func() error) (err error)

type Message struct {
	// contains filtered or unexported fields
}

func (this *Message) Wait(t time.Duration) (any, error)