concurrency

func NewManager ¶

func NewManager(max int32) (*Manager, error)

NewManager creates a new concurrency manager with validation

Usage:

// Create a manager that allows up to 10 concurrent operations
cm, err := NewManager(10)
if err != nil {
    log.Fatal(err)
}

// Example 1: Basic usage with context timeout
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()

if err := cm.Acquire(ctx); err != nil {
    // Handle acquisition failure (timeout/cancellation)
    return err
}
defer cm.Release()  // Always release when done

// Example 2: Non-blocking attempt
if acquired := cm.TryAcquire(); acquired {
    defer cm.Release()
    // Do work...
} else {
    // Handle busy case
}

// Example 3: Check metrics
metrics := cm.GetMetrics()
log.Printf("Current usage: %d/%d", metrics["current"], 10)