Function NewFastSemaphore

internal/semaphore.go:30–40

NewFastSemaphore creates a new fast semaphore with the given capacity.

(capacity int32)

// NewFastSemaphore creates a new fast semaphore with the given capacity.
func NewFastSemaphore(capacity int32) *FastSemaphore {
	ch := make(chan struct{}, capacity)
	// Pre-fill with tokens
	for i := int32(0); i < capacity; i++ {
		ch <- struct{}{}
	}
	return &FastSemaphore{
		tokens: ch,
		max:    capacity,
	}
}

// TryAcquire attempts to acquire a token without blocking.
// Returns true if successful, false if no tokens available.