sync

package

v0.2.0 Latest Latest Go to latest Published: Jun 15, 2020 License: Apache-2.0, MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func NewRWLock() *rwlock

func Test()

func Test1()

func Test2()

func Test3()

func Test4()

func Test5()

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

func NewEnv() *Env

func (e Env) Locker(notify chan<- struct{}) TestLocker

func (e *Env) NewRunner(name string, locker func(notify chan<- struct{}) TestLocker) *Runner

func (e Env) RLocker(notify chan<- struct{}) TestLocker

func (e *Env) TestSeq(name string, step ...func() error) bool

type Locker interface {
	Lock()
	Unlock()
}

type RWLock interface {
	Locker
	RLock()
	RUnlock()

	TestAndLock() bool
	TestAndRLock() bool

	RLocker() TestLocker
}

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

func (r *Runner) Blocked() error

func (r *Runner) Locked() error

func (r *Runner) NoLock() error

func (r *Runner) Step() error

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

func (this *SyncPoint) IsReached() bool

func (this *SyncPoint) Reach()

func (this *SyncPoint) Sync(ctx context.Context) bool

type TestLocker interface {
	Locker
	TestAndLock() bool
}

type WaitLock interface {
	Wait(ctx context.Context) bool
	Setup(ctx context.Context) WaitLock
	Release()
}