mysync

Documentation

Index

• func Distribute[S ~[]E, E any](items S, limit int, fn func(group int, step int, subitems S) error) error
• func Map[S ~[]E, E, R any](items S, limit int, out []R, fn func(subitems S) (R, error)) ([]R, error)
• type Mutex
  • func NewMutex[T any](v T) *Mutex[T]
  • func (mu *Mutex[T]) Lock() (T, MutexUnlock)
  • func (mu *Mutex[T]) RLock() (T, MutexRUnlock)
• type MutexRUnlock
  • func (u MutexRUnlock) RUnlock()
• type MutexUnlock
  • func (u MutexUnlock) Unlock()
• type Pool
  • func NewPool[T any](fn func() T) *Pool[T]
  • func (p *Pool[T]) Get() T
  • func (p *Pool[T]) Put(v T)

Functions

func Distribute

func Distribute[S ~[]E, E any](items S, limit int, fn func(group int, step int, subitems S) error) error

func Map

func Map[S ~[]E, E, R any](items S, limit int, out []R, fn func(subitems S) (R, error)) ([]R, error)

Types

type Mutex

type Mutex[T any] struct {
	// contains filtered or unexported fields
}

func NewMutex

func NewMutex[T any](v T) *Mutex[T]

func (*Mutex[T]) Lock

func (mu *Mutex[T]) Lock() (T, MutexUnlock)

func (*Mutex[T]) RLock

func (mu *Mutex[T]) RLock() (T, MutexRUnlock)

type MutexRUnlock

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

func (MutexRUnlock) RUnlock

func (u MutexRUnlock) RUnlock()

type MutexUnlock

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

func (MutexUnlock) Unlock

func (u MutexUnlock) Unlock()

type Pool

type Pool[T any] struct {
	// contains filtered or unexported fields
}

func NewPool

func NewPool[T any](fn func() T) *Pool[T]

func (*Pool[T]) Get

func (p *Pool[T]) Get() T

func (*Pool[T]) Put

func (p *Pool[T]) Put(v T)