locks

type ConditionVariable interface {
	// Signal wakes one goroutine waiting on this condition variable, if there is any.
	Signal()
	// Broadcast wakes all goroutines waiting on this condition variable.
	Broadcast()
	// Wait atomically unlocks user provided lock and suspends execution of the calling goroutine.
	// After later resuming execution, Wait locks c.L before returning.
	// Wait can be awoken by Broadcast, Signal or user provided interrupt channel.
	Wait(interrupt <-chan struct{})
}

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

type HashFunc func(any) uint32

type IDMutex interface {
	LockID(identifier any)
	UnlockID(identifier any)
}

type Locker interface {
	// Lock locks
	Lock()
	// Unlock unlocks
	Unlock()
}

type Priority uint32

type PriorityMutex interface {
	// LockHigh try to lock with high priority, use LockHigh / UnlockHigh pair to lock / unlock
	LockHigh(context.Context) error
	// LockLow try to lock with low priority, use LockLow / UnlockLow pair to lock / unlock
	LockLow(context.Context) error
	// UnlockHigh unlock with high priority, use LockHigh / UnlockHigh pair to lock / unlock
	UnlockHigh()
	// UnlockLow unlock with low priority, use LockLow / UnlockLow pair to lock / unlock
	UnlockLow()
	// TryLockHigh try to lock with high priority, return true if lock acquired
	// use TryLockHigh / UnlockHigh pair to lock / unlock
	TryLockHigh() bool
	// TryLockLow try to lock with high priority, return true if lock acquired
	// use TryLockLow / UnlockLow pair to lock / unlock
	TryLockLow() bool
	// IsLocked returns true if already locked
	IsLocked() bool
}

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

type PriorityMutexState int

type PrioritySemaphore interface {
	Acquire(ctx context.Context, priority Priority, n int) error
	TryAcquire(priority Priority, n int) bool
	Release(n int)
}

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