xnsyncutil

Documentation

Index

• type AtomicBool
  • func (ab *AtomicBool) Load() bool
  • func (ab *AtomicBool) Store(v bool)
• type AtomicInt
  • func (ai *AtomicInt) Add(delta int)
  • func (ai *AtomicInt) Load() int
  • func (ai *AtomicInt) Store(v int)
• type AtomicInt32
  • func (ai *AtomicInt32) Add(delta int32)
  • func (ai *AtomicInt32) Load() int32
  • func (ai *AtomicInt32) Store(v int32)
• type AtomicInt64
  • func (ai *AtomicInt64) Add(delta int64)
  • func (ai *AtomicInt64) Load() int64
  • func (ai *AtomicInt64) Store(v int64)
• type AtomicPointer
  • func (ap *AtomicPointer) Load() unsafe.Pointer
  • func (ap *AtomicPointer) Store(pointer unsafe.Pointer)
• type NewlessPool
  • func NewNewlessPool() *NewlessPool
  • func (pool *NewlessPool) Get() (v interface{})
  • func (pool *NewlessPool) Put(v interface{})
  • func (pool *NewlessPool) TryGet() (v interface{})
• type OneTimeCond
  • func NewOneTimeCond() *OneTimeCond
  • func (cond *OneTimeCond) IsSignalled() (signalled bool)
  • func (cond *OneTimeCond) Signal()
  • func (cond *OneTimeCond) Wait()
• type SpinLock
  • func (sl *SpinLock) Lock()
  • func (sl *SpinLock) Unlock()
• type SyncQueue
  • func NewSyncQueue() *SyncQueue
  • func (q *SyncQueue) Close()
  • func (q *SyncQueue) Len() (l int)
  • func (q *SyncQueue) Pop() (v interface{})
  • func (q *SyncQueue) Push(v interface{})
  • func (q *SyncQueue) TryPop() (v interface{}, ok bool)

Types

type AtomicBool

type AtomicBool AtomicInt

func (*AtomicBool) Load

func (ab *AtomicBool) Load() bool

Load bool value atomically

func (*AtomicBool) Store

func (ab *AtomicBool) Store(v bool)

Store bool value atomically

type AtomicInt

type AtomicInt int64

func (*AtomicInt) Add

func (ai *AtomicInt) Add(delta int)

Add int value atomically

func (*AtomicInt) Load

func (ai *AtomicInt) Load() int

Load int value atomically

func (*AtomicInt) Store

func (ai *AtomicInt) Store(v int)

Store int value atomically

type AtomicInt32

type AtomicInt32 int32

func (*AtomicInt32) Add

func (ai *AtomicInt32) Add(delta int32)

Add int value atomically

func (*AtomicInt32) Load

func (ai *AtomicInt32) Load() int32

Load int value atomically

func (*AtomicInt32) Store

func (ai *AtomicInt32) Store(v int32)

Store int value atomically

type AtomicInt64

type AtomicInt64 int64

func (*AtomicInt64) Add

func (ai *AtomicInt64) Add(delta int64)

Add int value atomically

func (*AtomicInt64) Load

func (ai *AtomicInt64) Load() int64

Load int value atomically

func (*AtomicInt64) Store

func (ai *AtomicInt64) Store(v int64)

Store int value atomically

type AtomicPointer

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

func (*AtomicPointer) Load

func (ap *AtomicPointer) Load() unsafe.Pointer

Load ptr value atomically

func (*AtomicPointer) Store

func (ap *AtomicPointer) Store(pointer unsafe.Pointer)

Store ptr value atomically

type NewlessPool

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

func NewNewlessPool

func NewNewlessPool() *NewlessPool

func (*NewlessPool) Get

func (pool *NewlessPool) Get() (v interface{})

func (*NewlessPool) Put

func (pool *NewlessPool) Put(v interface{})

func (*NewlessPool) TryGet

func (pool *NewlessPool) TryGet() (v interface{})

type OneTimeCond

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

Synchronous condition which can be signalled only once

func NewOneTimeCond

func NewOneTimeCond() *OneTimeCond

Create a new OneTimeCond

func (*OneTimeCond) IsSignalled

func (cond *OneTimeCond) IsSignalled() (signalled bool)

Return if the condition is already signalled

func (*OneTimeCond) Signal

func (cond *OneTimeCond) Signal()

Signal the condition

All goroutines waiting for the condition will be notified to continue

func (*OneTimeCond) Wait

func (cond *OneTimeCond) Wait()

Wait for condition to be signalled.

If the condition was signalled before Wait, Wait returns immediately without blocking.

type SpinLock

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

func (*SpinLock) Lock

func (sl *SpinLock) Lock()

func (*SpinLock) Unlock

func (sl *SpinLock) Unlock()

type SyncQueue

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

Synchronous FIFO queue

func NewSyncQueue

func NewSyncQueue() *SyncQueue

Create a new SyncQueue

func (*SyncQueue) Close

func (q *SyncQueue) Close()

Close SyncQueue

After close, Pop will return nil without block, and TryPop will return v=nil, ok=True

func (*SyncQueue) Len

func (q *SyncQueue) Len() (l int)

Get the length of SyncQueue

func (*SyncQueue) Pop

func (q *SyncQueue) Pop() (v interface{})

Pop an item from SyncQueue, will block if SyncQueue is empty

func (*SyncQueue) Push

func (q *SyncQueue) Push(v interface{})

Push an item to SyncQueue. Always returns immediately without blocking

func (*SyncQueue) TryPop

func (q *SyncQueue) TryPop() (v interface{}, ok bool)

Try to pop an item from SyncQueue, will return immediately with bool=false if SyncQueue is empty