Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

syncx

package

Go to main page

Versions in this module

v1

v1.2.2

Sep 16, 2021

v1.2.2-rc1

Sep 16, 2021

v1.2.1

Sep 14, 2021

Changes in this version

+ var ErrLimitReturn = errors.New(...)

+ var ErrTimeout = errors.New("borrow timeout")

+ var ErrUseOfCleaned = errors.New("using a cleaned resource")

+ func Guard(lock sync.Locker, fn func())

+ func Once(fn func()) func()

+ type AtomicBool uint32

+ func ForAtomicBool(val bool) *AtomicBool

+ func NewAtomicBool() *AtomicBool

+ func (b *AtomicBool) CompareAndSwap(old, val bool) bool

+ func (b *AtomicBool) Set(v bool)

+ func (b *AtomicBool) True() bool

+ type AtomicDuration int64

+ func ForAtomicDuration(val time.Duration) *AtomicDuration

+ func NewAtomicDuration() *AtomicDuration

+ func (d *AtomicDuration) CompareAndSwap(old, val time.Duration) bool

+ func (d *AtomicDuration) Load() time.Duration

+ func (d *AtomicDuration) Set(val time.Duration)

+ type AtomicFloat64 uint64

+ func ForAtomicFloat64(val float64) *AtomicFloat64

+ func NewAtomicFloat64() *AtomicFloat64

+ func (f *AtomicFloat64) Add(val float64) float64

+ func (f *AtomicFloat64) CompareAndSwap(old, val float64) bool

+ func (f *AtomicFloat64) Load() float64

+ func (f *AtomicFloat64) Set(val float64)

+ type Barrier struct

+ func (b *Barrier) Guard(fn func())

+ type Cond struct

+ func NewCond() *Cond

+ func (cond *Cond) Signal()

+ func (cond *Cond) Wait()

+ func (cond *Cond) WaitWithTimeout(timeout time.Duration) (time.Duration, bool)

+ type DoneChan struct

+ func NewDoneChan() *DoneChan

+ func (dc *DoneChan) Close()

+ func (dc *DoneChan) Done() chan lang.PlaceholderType

+ type ImmutableResource struct

+ func NewImmutableResource(fn func() (interface{}, error), opts ...ImmutableResourceOption) *ImmutableResource

+ func (ir *ImmutableResource) Get() (interface{}, error)

+ type ImmutableResourceOption func(resource *ImmutableResource)

+ func WithRefreshIntervalOnFailure(interval time.Duration) ImmutableResourceOption

+ type Limit struct

+ func NewLimit(n int) Limit

+ func (l Limit) Borrow()

+ func (l Limit) Return() error

+ func (l Limit) TryBorrow() bool

+ type LockedCalls interface

+ Do func(key string, fn func() (interface{}, error)) (interface{}, error)

+ func NewLockedCalls() LockedCalls

+ type ManagedResource struct

+ func NewManagedResource(generate func() interface{}, equals func(a, b interface{}) bool) *ManagedResource

+ func (mr *ManagedResource) MarkBroken(resource interface{})

+ func (mr *ManagedResource) Take() interface{}

+ type OnceGuard struct

+ func (og *OnceGuard) Take() bool

+ func (og *OnceGuard) Taken() bool

+ type Pool struct

+ func NewPool(n int, create func() interface{}, destroy func(interface{}), ...) *Pool

+ func (p *Pool) Get() interface{}

+ func (p *Pool) Put(x interface{})

+ type PoolOption func(*Pool)

+ func WithMaxAge(duration time.Duration) PoolOption

+ type RefResource struct

+ func NewRefResource(clean func()) *RefResource

+ func (r *RefResource) Clean()

+ func (r *RefResource) Use() error

+ type ResourceManager struct

+ func NewResourceManager() *ResourceManager

+ func (manager *ResourceManager) Close() error

+ func (manager *ResourceManager) GetResource(key string, create func() (io.Closer, error)) (io.Closer, error)

+ type SharedCalls = SingleFlight

+ type SingleFlight interface

+ Do func(key string, fn func() (interface{}, error)) (interface{}, error)

+ DoEx func(key string, fn func() (interface{}, error)) (interface{}, bool, error)

+ func NewSharedCalls() SingleFlight

+ func NewSingleFlight() SingleFlight

+ type SpinLock struct

+ func (sl *SpinLock) Lock()

+ func (sl *SpinLock) TryLock() bool

+ func (sl *SpinLock) Unlock()

+ type TimeoutLimit struct

+ func NewTimeoutLimit(n int) TimeoutLimit

+ func (l TimeoutLimit) Borrow(timeout time.Duration) error

+ func (l TimeoutLimit) Return() error

+ func (l TimeoutLimit) TryBorrow() bool

v1.2.1-sp1

Sep 15, 2021

v1.2.1-rc2

Sep 15, 2021

v1.2.1-rc1

Sep 15, 2021

v1.2.1-rc

Sep 15, 2021