sync2

Documentation

Index

• Constants
• type LockCond
  • func NewLockCond(l sync.Locker) *LockCond
  • func WrapCond(cond *sync.Cond) *LockCond
  • func (c *LockCond) Broadcast()
  • func (c *LockCond) Cond() *sync.Cond
  • func (c *LockCond) Signal()
  • func (c *LockCond) Wait()
• type MRWMutex
  • func NewMRWMutex() *MRWMutex
  • func (m *MRWMutex) Lock(lockId string)
  • func (m *MRWMutex) NewId(id string) string
  • func (m *MRWMutex) RLock(lockId string)
  • func (m *MRWMutex) RLocker(lockId string) sync.Locker
  • func (m *MRWMutex) RUnlock(lockId string)
  • func (m *MRWMutex) Unlock(lockId string)
• type Once
  • func (o *Once) Do(f func()) bool
• type Queue
  • func (q *Queue) Dequeue() Task
  • func (q *Queue) Enqueue(t Task) bool
• type Scheduler
  • func New() *Scheduler
  • func (s *Scheduler) AddQueue(id uint32, capacity int)
  • func (s *Scheduler) AddTask(id uint32, t Task) (success bool)
  • func (s *Scheduler) GetTask() Task
  • func (s *Scheduler) Run()
• type Signal
  • func NewSignal() *Signal
  • func (s *Signal) Notify()
  • func (s *Signal) Wait()
• type Spinlock
  • func (s *Spinlock) Lock()
  • func (s *Spinlock) Unlock()
• type Task
• type TaskFunc
  • func (f TaskFunc) Execute()

Constants

const APPEND = "01235"

Types

type LockCond

type LockCond sync.Cond

LockCond is a wrapper of sync.Cond, each method will be called with lock

func NewLockCond

func NewLockCond(l sync.Locker) *LockCond

func WrapCond

func WrapCond(cond *sync.Cond) *LockCond

func (*LockCond) Broadcast

func (c *LockCond) Broadcast()

func (*LockCond) Cond

func (c *LockCond) Cond() *sync.Cond

func (*LockCond) Signal

func (c *LockCond) Signal()

func (*LockCond) Wait

func (c *LockCond) Wait()

type MRWMutex

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

func NewMRWMutex

func NewMRWMutex() *MRWMutex

func (*MRWMutex) Lock

func (m *MRWMutex) Lock(lockId string)

func (*MRWMutex) NewId

func (m *MRWMutex) NewId(id string) string

func (*MRWMutex) RLock

func (m *MRWMutex) RLock(lockId string)

func (*MRWMutex) RLocker

func (m *MRWMutex) RLocker(lockId string) sync.Locker

func (*MRWMutex) RUnlock

func (m *MRWMutex) RUnlock(lockId string)

func (*MRWMutex) Unlock

func (m *MRWMutex) Unlock(lockId string)

type Once

type Once uint32

Once is an object that will perform exactly one action unless call Undo.

func (*Once) Do

func (o *Once) Do(f func()) bool

Do will do f only once no matter it's successful or not if f is blocked, Do will also be

type Queue

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

func (*Queue) Dequeue

func (q *Queue) Dequeue() Task

func (*Queue) Enqueue

func (q *Queue) Enqueue(t Task) bool

type Scheduler

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

func New

func New() *Scheduler

func (*Scheduler) AddQueue

func (s *Scheduler) AddQueue(id uint32, capacity int)

func (*Scheduler) AddTask

func (s *Scheduler) AddTask(id uint32, t Task) (success bool)

func (*Scheduler) GetTask

func (s *Scheduler) GetTask() Task

func (*Scheduler) Run

func (s *Scheduler) Run()

type Signal

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

func NewSignal

func NewSignal() *Signal

func (*Signal) Notify

func (s *Signal) Notify()

func (*Signal) Wait

func (s *Signal) Wait()

type Spinlock

type Spinlock int32

Spinlock should not be used on single cpu(core) machines. if one goroute take out the lock, the programm will be died if another goroutine try to take out the lock again

func (*Spinlock) Lock

func (s *Spinlock) Lock()

func (*Spinlock) Unlock

func (s *Spinlock) Unlock()

type Task

type Task interface {
	Execute()
}

Task Schedule By scale, each user has his scale

type TaskFunc

type TaskFunc func()

func (TaskFunc) Execute

func (f TaskFunc) Execute()