sync

Documentation

Overview

* 并发共享函数调用返回的库

Index

• func StartDeadCheck(lockNotify func(deadLockInfo []byte), ...)
• func StopDeadCheck()
• type LockInfo
  • func (lckInfo *LockInfo) String() string
• type LockStyle
• type MutexEx
  • func (mutex *MutexEx) Lock()
  • func (mutex *MutexEx) LockWithMsg(lockMsg string)
  • func (mutex *MutexEx) Unlock()
• type RWMutexEx
  • func (mutex *RWMutexEx) Lock()
  • func (mutex *RWMutexEx) LockWithMsg(lockMsg string)
  • func (mutex *RWMutexEx) RLock()
  • func (mutex *RWMutexEx) RLockWithMsg(lockMsg string)
  • func (mutex *RWMutexEx) RUnlock()
  • func (mutex *RWMutexEx) Unlock()
• type ShareCalls
  • func (calls *ShareCalls) ShareCall(shareID int, fn func(...interface{}) (interface{}, error), ...) (result interface{}, fromShareCache bool, err error)
  • func (calls *ShareCalls) ShareCallByKey(sharekey string, fn func(...interface{}) (interface{}, error), ...) (result interface{}, fromShareCache bool, err error)

Functions

func StartDeadCheck

func StartDeadCheck(lockNotify func(deadLockInfo []byte), checkInterval, maxLockInterval time.Duration, debugLog func(panicMsg bool, format string, data ...interface{}))

func StopDeadCheck

func StopDeadCheck()

Types

type LockInfo

type LockInfo struct {
	IsRLock      bool //是否是RLock
	LockStyle    LockStyle
	CheckIndex   byte //检查了多少次
	StartTime    time.Time
	GoRoutine    int64
	LockMsg      string
	Caller       string //调用Lock的位置
	CallerFunc   string //调用Lock的函数
	BeforeCaller string //前一步调用
	BeforeFunc   string //前一步调用
	Owner        *mutexStruct
}

func (*LockInfo) String

func (lckInfo *LockInfo) String() string

type LockStyle

type LockStyle uint8

const (
	LckUnLock    LockStyle = iota
	LckLockBlock           //LockWait
	LckLocking             //Locking
)

type MutexEx

type MutexEx struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*MutexEx) Lock

func (mutex *MutexEx) Lock()

func (*MutexEx) LockWithMsg

func (mutex *MutexEx) LockWithMsg(lockMsg string)

func (*MutexEx) Unlock

func (mutex *MutexEx) Unlock()

type RWMutexEx

type RWMutexEx struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*RWMutexEx) Lock

func (mutex *RWMutexEx) Lock()

func (*RWMutexEx) LockWithMsg

func (mutex *RWMutexEx) LockWithMsg(lockMsg string)

func (*RWMutexEx) RLock

func (mutex *RWMutexEx) RLock()

func (*RWMutexEx) RLockWithMsg

func (mutex *RWMutexEx) RLockWithMsg(lockMsg string)

func (*RWMutexEx) RUnlock

func (mutex *RWMutexEx) RUnlock()

func (*RWMutexEx) Unlock

func (mutex *RWMutexEx) Unlock()

type ShareCalls

type ShareCalls struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*ShareCalls) ShareCall

func (calls *ShareCalls) ShareCall(shareID int, fn func(...interface{}) (interface{}, error), params ...interface{}) (result interface{}, fromShareCache bool, err error)

func (*ShareCalls) ShareCallByKey

func (calls *ShareCalls) ShareCallByKey(sharekey string, fn func(...interface{}) (interface{}, error), params ...interface{}) (result interface{}, fromShareCache bool, err error)