Method LockWithContext

locking/local_locker.go:70–84

(ctx context.Context, key, identifier string)

}

func (k *keyMutex) LockWithContext(ctx context.Context, key, identifier string) error {
	ticker := time.NewTicker(time.Second)
	defer ticker.Stop()

	for {
		if k.TryLock(key, identifier) {
			return nil
		}
		select {
		case <-ctx.Done():
			return ctx.Err()
		case <-ticker.C:
		}
	}
}

func (k *keyMutex) Unlock(key string, remove bool) {
	mux, ok := k.muxes.Load(key)