fix leak memory

Author: manhvu

README.md

@@ -75,6 +75,8 @@ In restart case, children will re-use last parameters (if task don't change it)
 Child, doesn't return any value from task.
 You need add code to get value from task if you needed.
 
+After use the supervisor done, you need to remove by `RemoveSupervisor` or `RemoveSupervisorById` to avoid leak memory.
+
 Supervisor -> Child -> call user functions
 
 Basic supervisor's flow:
@@ -135,6 +137,9 @@ time.Sleep(15 * time.Second)
 // stop all worker.
 // this function depends how long fun return.
 sup.Stop()
+
+// clear all children in supervisor to avoid memory leak.
+sup.Done()
 ```
 
 Supervisor support context by create supervisor by function `NewSupervisorWithContext`.

caller.go

@@ -25,6 +25,7 @@ func invokeFun(fun any, args ...any) (ret []any, err error) {
 	fn := reflect.ValueOf(fun)
 	fnType := fn.Type()
 	numIn := fnType.NumIn()
+
 	if numIn > len(args) {
 		return nil, fmt.Errorf("function must have minimum %d params. Have %d", numIn, len(args))
 	}

stream.go

@@ -127,8 +127,9 @@ func (p *EasyStream) Run() (retErr error) {
 			cmd := <-p.cmdCh
 			switch cmd {
 			case iQUIT:
-				for _, w := range p.workerList {
+				for i, w := range p.workerList {
 					w.cmd <- msg{msgType: iQUIT}
+					delete(p.workerList, i)
 				}
 			}
 		}

supervisor.go

@@ -226,6 +226,15 @@ func (s *Supervisor) StopChild(id int64) {
 	}
 }
 
+/*
+Clear all children. Call after Stop.
+*/
+func (s *Supervisor) Done() {
+	for k := range s.children {
+		delete(s.children, k)
+	}
+}
+
 /*
 Return statistics of supervisor.
 total: Number of children in supervisor.