chanlock

Documentation

Overview

Package chanlock 基于chan实现trylock乐观锁

Index

• Variables
• type ChanLock
  • func NewChanLock() *ChanLock
  • func (l *ChanLock) Lock()
  • func (l *ChanLock) TryLock(timeout ...time.Duration) bool
  • func (l *ChanLock) Unlock()

Variables

var DefaultLockTimeout = 10 * time.Millisecond

DefaultLockTimeout 默认加锁超时时间20ms就认为加锁失败

Types

type ChanLock

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

ChanLock chan lock

func NewChanLock

func NewChanLock() *ChanLock

NewChanLock 实例化一个通道空结构体锁对象

func (*ChanLock) Lock

func (l *ChanLock) Lock()

Lock 通道加锁,如果无法放入ch，该方法就会阻塞，直到ch通道锁释放为止

func (*ChanLock) TryLock

func (l *ChanLock) TryLock(timeout ...time.Duration) bool

TryLock 乐观锁实现

func (*ChanLock) Unlock

func (l *ChanLock) Unlock()

Unlock实现通道解锁