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 SyncValue
  • func NewSyncValue[T any]() SyncValue[T]
  • func (s SyncValue[T]) Close() (e error)
  • func (s SyncValue[T]) Recv() <-chan T
  • func (s SyncValue[T]) Send() chan<- T
  • func (s SyncValue[T]) TimedRecv(dur time.Duration) (T, bool)
  • func (s SyncValue[T]) TimedSend(v T, dur time.Duration) bool
  • func (s SyncValue[T]) TryRecv() (T, bool)
  • func (s SyncValue[T]) TrySend(v T) bool
  • func (s SyncValue[T]) WaitRecv() T
  • func (s SyncValue[T]) WaitSend(v T)
• type Task
• type WaitPool
  • func NewWaitPool(ctx context.Context, maxGoroutine int) *WaitPool
  • func (p *WaitPool) Err() error
  • func (p *WaitPool) Go(f waitPoolTask) error
  • func (p *WaitPool) Wait() error
• type Waiter
  • func NewWaiter() *Waiter
  • func (w *Waiter) Close() (e error)
  • func (w *Waiter) Recv() <-chan struct{}
  • func (w *Waiter) Send() chan<- struct{}
  • func (w *Waiter) TimedRecv(dur time.Duration) bool
  • func (w *Waiter) TimedSend(dur time.Duration) bool
  • func (w *Waiter) TryRecv() bool
  • func (w *Waiter) TrySend() bool
  • func (w *Waiter) WaitRecv()
  • func (w *Waiter) WaitSend()

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

构造一个Closer

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 SyncValue

type SyncValue[T any] chan T

数据同步

func NewSyncValue

func NewSyncValue[T any]() SyncValue[T]

func (SyncValue[T]) Close

func (s SyncValue[T]) Close() (e error)

func (SyncValue[T]) Recv

func (s SyncValue[T]) Recv() <-chan T

func (SyncValue[T]) Send

func (s SyncValue[T]) Send() chan<- T

func (SyncValue[T]) TimedRecv

func (s SyncValue[T]) TimedRecv(dur time.Duration) (T, bool)

func (SyncValue[T]) TimedSend

func (s SyncValue[T]) TimedSend(v T, dur time.Duration) bool

func (SyncValue[T]) TryRecv

func (s SyncValue[T]) TryRecv() (T, bool)

func (SyncValue[T]) TrySend

func (s SyncValue[T]) TrySend(v T) bool

func (SyncValue[T]) WaitRecv

func (s SyncValue[T]) WaitRecv() T

func (SyncValue[T]) WaitSend

func (s SyncValue[T]) WaitSend(v T)

type Task

type Task func(context.Context)

type WaitPool

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

func NewWaitPool

func NewWaitPool(ctx context.Context, maxGoroutine int) *WaitPool

func (*WaitPool) Err

func (p *WaitPool) Err() error

func (*WaitPool) Go

func (p *WaitPool) Go(f waitPoolTask) error

func (*WaitPool) Wait

func (p *WaitPool) Wait() error

调用Wait()后，等待任务执行完毕，不能再开启任务，退出goroutine

type Waiter

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

同步执行

func NewWaiter

func NewWaiter() *Waiter

func (*Waiter) Close

func (w *Waiter) Close() (e error)

func (*Waiter) Recv

func (w *Waiter) Recv() <-chan struct{}

func (*Waiter) Send

func (w *Waiter) Send() chan<- struct{}

func (*Waiter) TimedRecv

func (w *Waiter) TimedRecv(dur time.Duration) bool

成功收到信号返回true，超时返回false

func (*Waiter) TimedSend

func (w *Waiter) TimedSend(dur time.Duration) bool

成功发送信号返回true，超时返回false

func (*Waiter) TryRecv

func (w *Waiter) TryRecv() bool

尝试读

func (*Waiter) TrySend

func (w *Waiter) TrySend() bool

尝试写

func (*Waiter) WaitRecv

func (w *Waiter) WaitRecv()

func (*Waiter) WaitSend

func (w *Waiter) WaitSend()