sync

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 29, 2016

Changes in this version

type SemaMutex — darwin/amd64, js/wasm, windows/amd64

+ func (m *SemaMutex) LockTimeout(timeout time.Duration) bool

type Semaphore

+ func (s *Semaphore) Close() error

+ func (s *Semaphore) WaitTimeout(timeout time.Duration) bool

+ type WindowsEvent struct — windows/amd64

+ func NewWindowsEvent(name string, flag int, perm os.FileMode, initial bool) (*WindowsEvent, error)

+ func (e *WindowsEvent) Close() error

+ func (e *WindowsEvent) Set()

+ func (e *WindowsEvent) Wait()

+ func (e *WindowsEvent) WaitTimeout(timeout time.Duration) bool

v0.4.0

Dec 18, 2016

Changes in this version

+ const CSemMaxVal

+ func DestroyEvent(name string) error

+ func DestroyRWMutex(name string) error

+ func DestroySemaMutex(name string) error — js/wasm, windows/amd64

+ func DestroySemaphore(name string) error

+ type Event event

+ func NewEvent(name string, flag int, perm os.FileMode, initial bool) (*Event, error)

+ func (e *Event) Close() error

+ func (e *Event) Destroy() error

+ func (e *Event) Set()

+ func (e *Event) Wait()

+ func (e *Event) WaitTimeout(timeout time.Duration) bool

type EventMutex — windows/amd64

+ func (m *EventMutex) TryLock() bool

type FutexMutex — linux/amd64

+ func (f *FutexMutex) TryLock() bool

+ type RWMutex struct

+ func NewRWMutex(name string, flag int, perm os.FileMode) (*RWMutex, error)

+ func (rw *RWMutex) Close() error

+ func (rw *RWMutex) Destroy() error

+ func (rw *RWMutex) Lock()

+ func (rw *RWMutex) RLock()

+ func (rw *RWMutex) RLocker() IPCLocker

+ func (rw *RWMutex) RUnlock()

+ func (rw *RWMutex) Unlock()

+ type SemaMutex struct — js/wasm, windows/amd64

+ func NewSemaMutex(name string, flag int, perm os.FileMode) (*SemaMutex, error)

+ func (m *SemaMutex) Close() error

+ func (m *SemaMutex) Destroy() error

+ func (m *SemaMutex) Lock()

+ func (m *SemaMutex) TryLock() bool

+ func (m *SemaMutex) Unlock()

+ type Semaphore interface — js/wasm, windows/amd64

+ Signal func(count int)

+ Wait func()

+ func NewSemaphore(name string, flag int, perm os.FileMode, initial int) (Semaphore, error)

+ type TimedSemaphore interface

+ WaitTimeout func(timeout time.Duration) bool

v0.3.0

Oct 12, 2016

Changes in this version

+ var ErrTooManyWaiters = errors.New("waiters limit has been reached")

+ var MaxCondWaiters = 128

+ func DestroyCond(name string) error

+ func FutexWait(addr unsafe.Pointer, value uint32, timeout time.Duration, flags int32) error — linux/amd64

+ func FutexWake(addr unsafe.Pointer, count uint32, flags int32) (int, error) — linux/amd64

+ type Cond struct

+ func NewCond(name string, flag int, perm os.FileMode, l IPCLocker) (*Cond, error)

+ func (c *Cond) Broadcast()

+ func (c *Cond) Close() error

+ func (c *Cond) Destroy() error

+ func (c *Cond) Signal()

+ func (c *Cond) Wait()

+ func (c *Cond) WaitTimeout(timeout time.Duration) bool

+ type InplaceMutex uint32 — linux/amd64

+ func NewInplaceMutex(ptr unsafe.Pointer) *InplaceMutex

+ func (f *InplaceMutex) Init()

+ func (f *InplaceMutex) Lock()

+ func (f *InplaceMutex) LockTimeout(timeout time.Duration) bool

+ func (f *InplaceMutex) TryLock() bool

+ func (f *InplaceMutex) Unlock()

type SpinMutex

+ func (spin *SpinMutex) LockTimeout(timeout time.Duration) bool

v0.2.0

Jun 22, 2016

v0.1.0

May 23, 2016

Changes in this version

+ const FUTEX_CLOCK_REALTIME — linux/amd64

+ const FUTEX_PRIVATE_FLAG — linux/amd64

+ func DestroyEventMutex(name string) error — windows/amd64

+ func DestroyFutexMutex(name string) error — linux/amd64

+ func DestroyMutex(name string) error

+ func DestroySemaMutex(name string) error — darwin/amd64, linux/amd64

+ func DestroySpinMutex(name string) error

+ type EventMutex struct — windows/amd64

+ func NewEventMutex(name string, flag int, perm os.FileMode) (*EventMutex, error)

+ func (m *EventMutex) Close() error

+ func (m *EventMutex) Lock()

+ func (m *EventMutex) LockTimeout(timeout time.Duration) bool

+ func (m *EventMutex) Unlock()

+ type Futex struct — linux/amd64

+ func NewFutex(uaddr unsafe.Pointer) *Futex

+ func (f *Futex) Addr() *uint32

+ func (f *Futex) Wait(value uint32, timeout time.Duration, flags int32) error

+ func (f *Futex) Wake(count uint32, flags int32) (int, error)

+ type FutexMutex struct — linux/amd64

+ func NewFutexMutex(name string, flag int, perm os.FileMode) (*FutexMutex, error)

+ func (f *FutexMutex) Close() error

+ func (f *FutexMutex) Destroy() error

+ func (f *FutexMutex) Lock()

+ func (f *FutexMutex) LockTimeout(timeout time.Duration) bool

+ func (f *FutexMutex) Unlock()

+ type IPCFutex struct — linux/amd64

+ func NewIPCFutex(name string, flag int, perm os.FileMode, initial uint32) (*IPCFutex, error)

+ func (f *IPCFutex) Addr() *uint32

+ func (f *IPCFutex) Close() error

+ func (f *IPCFutex) Destroy() error

+ func (f *IPCFutex) Wait(value uint32, timeout time.Duration) error

+ func (f *IPCFutex) Wake(count uint32) (int, error)

+ type IPCLocker interface

+ func NewMutex(name string, flag int, perm os.FileMode) (IPCLocker, error)

+ type SemaMutex struct — darwin/amd64, linux/amd64

+ func NewSemaMutex(name string, flag int, perm os.FileMode) (*SemaMutex, error)

+ func (m *SemaMutex) Close() error

+ func (m *SemaMutex) Destroy() error

+ func (m *SemaMutex) Lock()

+ func (m *SemaMutex) LockTimeout(timeout time.Duration) bool

+ func (m *SemaMutex) Unlock()

+ type Semaphore struct — darwin/amd64, linux/amd64

+ func NewSemaphore(name string, mode int, perm os.FileMode, initial int) (*Semaphore, error)

+ func NewSemaphoreKey(key uint64, flag int, perm os.FileMode, initial int) (*Semaphore, error)

+ func (s *Semaphore) Add(value int) error

+ func (s *Semaphore) AddTimeout(timeout time.Duration, value int) error

+ func (s *Semaphore) Destroy() error

+ type SpinMutex struct

+ func NewSpinMutex(name string, flag int, perm os.FileMode) (*SpinMutex, error)

+ func (spin *SpinMutex) Close() error

+ func (spin *SpinMutex) Destroy() error

+ func (spin SpinMutex) Lock()

+ func (spin SpinMutex) TryLock() bool

+ func (spin SpinMutex) Unlock()

+ type TimedIPCLocker interface

+ LockTimeout func(timeout time.Duration) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL