Separate LenGoroutines into Len and Groutines

goroutine.go

@@ -40,7 +40,7 @@ func (g *Goroutine) Start() {
 				return
 			case t := <-g.Pipe:
 				g.SetStatus(Progress)
-				executeTask(g.ctx, t)
+				ExecuteTask(g.ctx, t)
 				g.SetStatus(Idle)
 			}
 		}
@@ -63,19 +63,3 @@ func (g Goroutine) Status() Status {
 func (g *Goroutine) Kill() {
 	g.cnl()
 }
-
-func executeTask(ctx context.Context, task Task) {
-	err := task.execute(ctx)
-	if err == nil {
-		if task.success != nil {
-			task.success()
-		}
-	} else {
-		if task.fail != nil {
-			task.fail(err)
-		}
-	}
-	if task.final != nil {
-		task.final()
-	}
-}

pool.go

@@ -3,7 +3,6 @@ package pooli
 import (
 	"context"
 	"math"
-	"sync"
 )
 
 type Pool struct {
@@ -12,7 +11,7 @@ type Pool struct {
 	goroutines []*Goroutine
 	pipe       chan Task
 
-	m *sync.RWMutex
+	// m *sync.RWMutex
 }
 
 func Open(goroutines int) *Pool {
@@ -30,7 +29,7 @@ func Open(goroutines int) *Pool {
 		ctx:        ctx,
 		goroutines: grs,
 		pipe:       pipe,
-		m:          new(sync.RWMutex),
+		// m:          new(sync.RWMutex),
 	}
 }
 
@@ -64,22 +63,31 @@ func (p *Pool) SetGoroutines(n int) {
 		n = int(math.Abs(float64(n)))
 		for i := 0; i < n; i++ {
 			g := NewGoroutine(p.ctx, p.pipe)
-			g.Start()
-			p.goroutines = append(p.goroutines, g)
+			p.AddGoroutine(g)
 		}
 	}
 }
 
-func (p *Pool) LenGoroutines() int {
+func (p *Pool) Len() int {
 	return len(p.goroutines)
 }
 
+func (p *Pool) Goroutines() []*Goroutine {
+	return p.goroutines
+}
+
+func (p *Pool) AddGoroutine(g *Goroutine) {
+	g.Start()
+	p.goroutines = append(p.goroutines, g)
+}
+
 func (p *Pool) RemoveGoroutine(g *Goroutine) {
 	for i, gr := range p.goroutines {
 		if gr != g {
 			continue
 		}
 
+		gr.cnl()
 		p.goroutines = append(p.goroutines[:i], p.goroutines[i+1:]...)
 	}
 }

task.go

@@ -27,3 +27,19 @@ func (t Task) Final(f func()) Task {
 	t.final = f
 	return t
 }
+
+func ExecuteTask(ctx context.Context, task Task) {
+	err := task.execute(ctx)
+	if err == nil {
+		if task.success != nil {
+			task.success()
+		}
+	} else {
+		if task.fail != nil {
+			task.fail(err)
+		}
+	}
+	if task.final != nil {
+		task.final()
+	}
+}