Source File
	lock.go

Belonging Package
	go.pact.im/x/supervisor

package supervisor

import (
	"context"
)

// chanLock is a mutually exclusive lock that supports canceling acquire operation.
type chanLock chan struct{}

// newChanLock returns a new Lock that allows at most one goroutine to acquire it.
func newChanLock() chanLock {
	return make(chanLock, 1)
}

// Acquire locks c. If the lock is already in use, the calling goroutine blocks
// until either the lock is available or the context expires. It returns nil
// if the lock was acquired and a non-nil context error otherwise.
func (c chanLock) Acquire(ctx context.Context) error {
	select {
	case <-ctx.Done():
		return ctx.Err()
	case c <- struct{}{}:
		return nil
	}
}

// Release unlocks c. Unlike sync.Mutex, it is valid to release a Lock without
// a corresponding Acquire. In that case the next Acquire call will unlock the
// Release.
func (c chanLock) Release() {
	<-c
}

The pages are generated with Golds v0.7.6. (GOOS=linux GOARCH=amd64)