syncutils

Documentation

Index

• type KRWMutex
  • func NewKRWMutex() *KRWMutex
  • func (kwrMutex *KRWMutex) Free(key interface{})
  • func (krwMutex *KRWMutex) Register(key interface{}) (result *RWMutex)
• type LockableEntity
• type MultiMutex
  • func NewMultiMutex() *MultiMutex
  • func (mutex *MultiMutex) Lock(identifiers ...interface{})
  • func (mutex *MultiMutex) LockEntity(entity LockableEntity)
  • func (mutex *MultiMutex) Unlock(identifiers ...interface{})
  • func (mutex *MultiMutex) UnlockEntity(entity LockableEntity)
• type MultiMutexLockBuilder
  • func (lockBuilder *MultiMutexLockBuilder) AddLock(identifier interface{}) *MultiMutexLockBuilder
  • func (lockBuilder *MultiMutexLockBuilder) Build() []interface{}
• type Mutex
• type RWMultiMutex
  • func (mutex *RWMultiMutex) Lock(identifiers ...interface{})
  • func (mutex *RWMultiMutex) RLock(identifiers ...interface{})
  • func (mutex *RWMultiMutex) RUnlock(identifiers ...interface{})
  • func (mutex *RWMultiMutex) Unlock(identifiers ...interface{})
• type RWMutex

Types

type KRWMutex

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

func NewKRWMutex

func NewKRWMutex() *KRWMutex

func (*KRWMutex) Free

func (kwrMutex *KRWMutex) Free(key interface{})

func (*KRWMutex) Register

func (krwMutex *KRWMutex) Register(key interface{}) (result *RWMutex)

type LockableEntity

type LockableEntity interface {
	// Locks returns the locks that the entity needs to lock.
	Locks() (locks []interface{})
}

LockableEntity is an interface that allows to lock (and unlock) entities that are generating complex locks.

type MultiMutex

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

func NewMultiMutex

func NewMultiMutex() *MultiMutex

func (*MultiMutex) Lock

func (mutex *MultiMutex) Lock(identifiers ...interface{})

func (*MultiMutex) LockEntity

func (mutex *MultiMutex) LockEntity(entity LockableEntity)

LockEntity locks all locks that are required for the given LockEntity.

func (*MultiMutex) Unlock

func (mutex *MultiMutex) Unlock(identifiers ...interface{})

func (*MultiMutex) UnlockEntity

func (mutex *MultiMutex) UnlockEntity(entity LockableEntity)

UnlockEntity unlocks all locks that are required for the given LockEntity.

type MultiMutexLockBuilder

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

func (*MultiMutexLockBuilder) AddLock

func (lockBuilder *MultiMutexLockBuilder) AddLock(identifier interface{}) *MultiMutexLockBuilder

func (*MultiMutexLockBuilder) Build

func (lockBuilder *MultiMutexLockBuilder) Build() []interface{}

type Mutex

type Mutex = sync.Mutex

type RWMultiMutex

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

func (*RWMultiMutex) Lock

func (mutex *RWMultiMutex) Lock(identifiers ...interface{})

func (*RWMultiMutex) RLock

func (mutex *RWMultiMutex) RLock(identifiers ...interface{})

func (*RWMultiMutex) RUnlock

func (mutex *RWMultiMutex) RUnlock(identifiers ...interface{})

func (*RWMultiMutex) Unlock

func (mutex *RWMultiMutex) Unlock(identifiers ...interface{})

type RWMutex

type RWMutex = sync.RWMutex