Method Acquire

internal/semaphore.go:56–90

Acquire acquires a token, blocking if necessary until one is available. Returns an error if the context is cancelled or the timeout expires. Uses a fast path to avoid timer allocation when tokens are immediately available.

(ctx context.Context, timeout time.Duration, timeoutErr error)

// Returns an error if the context is cancelled or the timeout expires.
// Uses a fast path to avoid timer allocation when tokens are immediately available.
func (s *FastSemaphore) Acquire(ctx context.Context, timeout time.Duration, timeoutErr error) error {
	// Check context first
	select {
	case <-ctx.Done():
		return ctx.Err()
	default:
	}

	// Try fast path first (no timer needed)
	select {
	case <-s.tokens:
		return nil
	default:
	}

	// Slow path: need to wait with timeout
	timer := semTimers.Get().(*time.Timer)
	defer semTimers.Put(timer)
	timer.Reset(timeout)

	select {
	case <-s.tokens:
		if !timer.Stop() {
			<-timer.C
		}
		return nil
	case <-ctx.Done():
		if !timer.Stop() {
			<-timer.C
		}
		return ctx.Err()
	case <-timer.C:
		return timeoutErr
	}
}

// AcquireBlocking acquires a token, blocking indefinitely until one is available.
func (s *FastSemaphore) AcquireBlocking() {