sync

Documentation

Index

• func LockGuard(l sync.Locker, chunk func())
• func RLockGuard(l RLocker, chunk func())
• type Closer
  • func NewClosed() Closer
  • func NewCloser() Closer
• type GoPool
  • func NewGoPool(opts ...GoPoolOption) *GoPool
  • func (p *GoPool) Close()
  • func (p *GoPool) Go(f Task) (e error)
  • func (p *GoPool) IsWorking() bool
  • func (p *GoPool) MustGo(f Task) (e error)
  • func (p *GoPool) TryGo(f Task) (ok bool)
• type GoPoolOption
  • func GoLifetime(n time.Duration) GoPoolOption
  • func MaxGoroutine(n int) GoPoolOption
  • func MinGoroutine(n int) GoPoolOption
• type GoPoolStatus
• type RLocker
• type Task

Functions

func LockGuard

func LockGuard(l sync.Locker, chunk func())

func RLockGuard

func RLockGuard(l RLocker, chunk func())

Types

type Closer

type Closer interface {
	io.Closer
	IsClosed() bool
	Done() <-chan struct{}
	Wait()
}

stopper与closer的区别在于，Close()返回error，而Stop()返回是否执行了停止

func NewClosed

func NewClosed() Closer

func NewCloser

func NewCloser() Closer

构造一个Stopper

type GoPool

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

func NewGoPool

func NewGoPool(opts ...GoPoolOption) *GoPool

func (*GoPool) Close

func (p *GoPool) Close()

func (*GoPool) Go

func (p *GoPool) Go(f Task) (e error)

执行一个任务，如果没有空闲goroutine则等待

func (*GoPool) IsWorking

func (p *GoPool) IsWorking() bool

判断是否存在任务正在执行

func (*GoPool) MustGo

func (p *GoPool) MustGo(f Task) (e error)

执行一个任务，如果没有空闲goroutine则直接执行

func (*GoPool) TryGo

func (p *GoPool) TryGo(f Task) (ok bool)

尝试执行一个任务，如果没有空闲goroutine则返回false

type GoPoolOption

type GoPoolOption func(*GoPool)

func GoLifetime

func GoLifetime(n time.Duration) GoPoolOption

goroutine最低保留时间

func MaxGoroutine

func MaxGoroutine(n int) GoPoolOption

最多开启goroutine个数

func MinGoroutine

func MinGoroutine(n int) GoPoolOption

保留最少goroutine个数

type GoPoolStatus

type GoPoolStatus = int32

type RLocker

type RLocker interface {
	RLock()
	RUnlock()
}

type Task

type Task func(context.Context)