syncx

Documentation

Index

• Constants
• func Async(fn func() Value) chan Value
• func CancelCtx() (ctx context.Context, cancel context.CancelFunc)
• func GoChan(fn func() Value) chan Value
• func GoCtx(fn func(ctx context.Context), cb ...func(err error)) context.CancelFunc
• func GoDelay(fn func(), durations ...time.Duration)
• func GoSafe(fn func(), cb ...func(err error))
• func Monitor(timeout time.Duration, run func(), errFn func(err error))
• func Timeout(dur time.Duration, fn func()) (gErr error)
• type Promise
  • func Yield(fn func() (interface{}, error)) *Promise
  • func YieldGroup(fn func(in chan<- *Promise) error) *Promise
  • func (t *Promise) Await() (interface{}, error)
  • func (t *Promise) Err() error
  • func (t *Promise) Range(fn func(interface{})) error
  • func (t *Promise) Unwrap() <-chan interface{}
• type Value
  • func Wait(val ...chan Value) []Value
  • func WithErr(err error) Value
  • func WithVal(val interface{}, err ...error) Value
• type WaitGroup
  • func (t *WaitGroup) Add(delta int)
  • func (t *WaitGroup) Count() uint32
  • func (t *WaitGroup) Dec()
  • func (t *WaitGroup) Done()
  • func (t *WaitGroup) Inc()
  • func (t *WaitGroup) Wait()

Constants

const DefaultConcurrent = 16

const Name = "syncx"

Functions

func Async

func Async(fn func() Value) chan Value

Async 通过chan的方式同步执行异步任务

func CancelCtx

func CancelCtx() (ctx context.Context, cancel context.CancelFunc)

func GoChan

func GoChan(fn func() Value) chan Value

GoChan 通过chan的方式同步执行异步任务

func GoCtx

func GoCtx(fn func(ctx context.Context), cb ...func(err error)) context.CancelFunc

GoCtx 可取消并发处理

func GoDelay

func GoDelay(fn func(), durations ...time.Duration)

GoDelay 异步延迟处理

func GoSafe

func GoSafe(fn func(), cb ...func(err error))

GoSafe 安全并发处理

func Monitor

func Monitor(timeout time.Duration, run func(), errFn func(err error))

func Timeout

func Timeout(dur time.Duration, fn func()) (gErr error)

Timeout 超时处理

Types

type Promise

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

func Yield

func Yield(fn func() (interface{}, error)) *Promise

func YieldGroup

func YieldGroup(fn func(in chan<- *Promise) error) *Promise

func (*Promise) Await

func (t *Promise) Await() (interface{}, error)

func (*Promise) Err

func (t *Promise) Err() error

func (*Promise) Range

func (t *Promise) Range(fn func(interface{})) error

func (*Promise) Unwrap

func (t *Promise) Unwrap() <-chan interface{}

type Value

type Value interface {
	Val() interface{}
	Err() error
	IsErr() bool
}

func Wait

func Wait(val ...chan Value) []Value

func WithErr

func WithErr(err error) Value

func WithVal

func WithVal(val interface{}, err ...error) Value

type WaitGroup

type WaitGroup struct {
	Concurrent uint32
	// contains filtered or unexported fields
}

func (*WaitGroup) Add

func (t *WaitGroup) Add(delta int)

func (*WaitGroup) Count

func (t *WaitGroup) Count() uint32

func (*WaitGroup) Dec

func (t *WaitGroup) Dec()

func (*WaitGroup) Done

func (t *WaitGroup) Done()

func (*WaitGroup) Inc

func (t *WaitGroup) Inc()

func (*WaitGroup) Wait

func (t *WaitGroup) Wait()