sdconcur

Documentation

Overview

Package sdconcurr 并发/并行工具包

Index

• Variables
• func Bind[T any](l []T, action func(int, T)) []func()
• func Do[T any](n int, l []T, action func(int, T)) error
• func DoFuncs(n int, actions []func()) error
• func Lock(mtx *sync.Mutex, action func())
• func LockR(mtx *sync.RWMutex, action func())
• func LockW(mtx *sync.RWMutex, action func())
• type Pool
  • func NewPool(size int, opts *PoolOptions) (*Pool, error)
  • func (p *Pool) Close() error
  • func (p *Pool) Do(action func()) error
  • func (p *Pool) NumCap() int
  • func (p *Pool) NumFree() int
  • func (p *Pool) NumRunning() int
  • func (p *Pool) Submit(action func()) error
  • func (p *Pool) Wrap(action func()) func()
• type PoolOptions

Variables

var (
	ErrInvalidPoolExpiry   = ants.ErrInvalidPoolExpiry
	ErrLackPoolFunc        = ants.ErrLackPoolFunc
	ErrPoolClosed          = ants.ErrPoolClosed
	ErrPoolOverload        = ants.ErrPoolOverload
	ErrInvalidPreAllocSize = ants.ErrInvalidPreAllocSize
)

Functions

func Bind

func Bind[T any](l []T, action func(int, T)) []func()

func Do

func Do[T any](n int, l []T, action func(int, T)) error

func DoFuncs

func DoFuncs(n int, actions []func()) error

func Lock

func Lock(mtx *sync.Mutex, action func())

func LockR

func LockR(mtx *sync.RWMutex, action func())

func LockW

func LockW(mtx *sync.RWMutex, action func())

Types

type Pool

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

func NewPool

func NewPool(size int, opts *PoolOptions) (*Pool, error)

func (*Pool) Close

func (p *Pool) Close() error

func (*Pool) Do

func (p *Pool) Do(action func()) error

func (*Pool) NumCap

func (p *Pool) NumCap() int

func (*Pool) NumFree

func (p *Pool) NumFree() int

func (*Pool) NumRunning

func (p *Pool) NumRunning() int

func (*Pool) Submit

func (p *Pool) Submit(action func()) error

func (*Pool) Wrap

func (p *Pool) Wrap(action func()) func()

type PoolOptions

type PoolOptions = ants.Options