remove broken concurrency limiter

Author: negrel

nursery.go

@@ -26,7 +26,6 @@ type nursery struct {
 	cancel        func()
 	onError       func(error)
 	errors        chan error
-	limiter       limiter
 	goRoutine     chan Routine
 	routinesCount atomic.Int32
 }
@@ -37,7 +36,6 @@ func newNursery() *nursery {
 		cancel:    nil,
 		onError:   nil,
 		errors:    make(chan error),
-		limiter:   nil,
 		goRoutine: make(chan func() error),
 	}
 
@@ -60,22 +58,12 @@ func (n *nursery) Go(routine func() error) {
 		panic("use of nursery after end of block")
 	}
 
-	if n.limiter == nil {
-		select {
-		case n.goRoutine <- routine:
-			// Successfully reused a goroutine.
-		default:
-			// No goroutine available, spawn a new one.
-			n.goNew(routine)
-		}
-	} else {
-		select {
-		case n.limiter <- struct{}{}:
-			// We are below our limit.
-			n.goNew(routine)
-		case n.goRoutine <- routine:
-			// Successfully reused a goroutine.
-		}
+	select {
+	case n.goRoutine <- routine:
+		// Successfully reused a goroutine.
+	default:
+		// No goroutine available, spawn a new one.
+		n.goNew(routine)
 	}
 }
 

options.go

@@ -71,20 +71,3 @@ func WithIgnoreErrors() BlockOption {
 		n.onError = func(err error) {}
 	}
 }
-
-// WithMaxGoroutines returns a nursery block option that limits the maximum
-// number of goroutine running concurrently. If max is zero, number of goroutine
-// is unlimited. This function panics if max is negative.
-func WithMaxGoroutines(max int) BlockOption {
-	return func(n *nursery) {
-		if max < 0 {
-			panic("max goroutine option must be a non negative integer")
-		} else if max == 0 {
-			n.limiter = nil
-			return
-		}
-
-		// +1 because block function is a routine also.
-		n.limiter = make(chan struct{}, max+1)
-	}
-}