update doc & test case

Author: manhvu

README.md

@@ -68,6 +68,7 @@ Currently, child has three type of restart strategy:
 * NO_RESTART, supervisor will don't restart children for any reason.
 
 Children will be started after they are added to supervisor.
+Chid can be added many times to many supervisor but child can control only by the last supervior.
 
 In restart case, children will re-use last parameters (if task don't change it) of task.
 
@@ -118,11 +119,12 @@ sup := easyworker.NewSupervisor()
 
 // add direct child to supervisor.
 sup.NewChild(easyworker.ERROR_RESTART, loop, 5)
-sup.NewChild(easyworker.NO_RESTART, loopWithPanic, 5, "test panic")
-
+sup.NewChild(easyworker.NO_RESTART, func() {
+  fmt.Println("Hello")
+})
 
 // create a child.
-child, _ := easyworker.NewChild(easyworker.ALWAYS_RESTART, loopWithPanic, 5, "other panic")
+child, _ := easyworker.NewChild(easyworker.ALWAYS_RESTART, loopWithPanic, 5, "test panic")
 
 // add exists child.
 sup.AddChild(&child)
@@ -171,8 +173,6 @@ sup := NewSupervisorWithContext(context.Background())
 sup.NewChild(easyworker.NO_RESTART, loopWithContext, 10)
 ```
 
-For other APIs please go to [pkg.go](https://pkg.go.dev/github.com/manhvu/easyworker)
-
 ### EasyTask
 
 This is simple way to run parallel tasks.
@@ -352,3 +352,5 @@ if sig.Signal != easyWorker.SIGNAL_DONE {
  g.Run()
 }
 ```
+
+For other APIs please go to [pkg.go](https://pkg.go.dev/github.com/manhvu/easyworker)

child.go

@@ -62,6 +62,8 @@ type Child struct {
 	fun    any
 	params []any
 	ctx    context.Context
+
+	result []any
 }
 
 /*
@@ -131,7 +133,7 @@ func (c *Child) run_task() {
 l:
 	for {
 		// call user define function.
-		_, err = invokeFun(c.fun, c.params...)
+		c.result, err = invokeFun(c.fun, c.params...)
 
 		if err != nil {
 			c.incFailed()
@@ -201,3 +203,13 @@ func (c *Child) GetStats() (status int64, restarted int64, failed int64) {
 
 	return
 }
+
+/*
+Get result from last run.
+Result is slice of any.
+Length of slice is number of parameter return from user function.
+Cast type to get right value.
+*/
+func (c *Child) GetResult() []any {
+	return c.result
+}

gomonitor.go

@@ -216,7 +216,7 @@ func (g *Go) run_task() {
 Return state of Go.
 Kind of state:
   - RUNNING: Task is running.
-  - STOPPED: Stop by user. In this state user can run again.
+  - STOPPED: Stop by user. In this state user cannot run again.
   - STANDBY: Task is standby wait for start or just done task.
 */
 func (g *Go) State() int64 {
@@ -227,7 +227,7 @@ func (g *Go) State() int64 {
 Get result from last run.
 Result is slice of any.
 Length of slice is number of parameter return from user function.
-Cast type to get right value.
+Cast to right type for value.
 */
 func (g *Go) GetResult() []any {
 	g.lock.Lock()

supervisor.go

@@ -9,7 +9,10 @@ import (
 type key int
 
 const (
+	// Use to get supervisor id from context.
 	CTX_SUP_ID key = iota
+
+	// Use to get child id from context.
 	CTX_CHILD_ID
 )
 
@@ -103,6 +106,7 @@ func (s *Supervisor) NewChild(restart int, fun any, params ...any) (id int64, er
 	s.children[child.id] = child
 	child.cmdCh = s.cmdCh
 
+	// start child to run task.
 	child.run()
 
 	id = child.id

supervisor_test.go

@@ -69,7 +69,7 @@ func TestSupAlwaysRestart1(t *testing.T) {
 
 	sup := NewSupervisor()
 
-	child, _ := NewChild(ALWAYS_RESTART, loopRun, 5, ch)
+	child, _ := NewChild(ALWAYS_RESTART, loopRun, 15, ch)
 
 	sup.AddChild(&child)
 
@@ -254,23 +254,25 @@ func TestSupStopChild(t *testing.T) {
 func TestSupMultiWorkers(t *testing.T) {
 	sup := NewSupervisor()
 
-	for i := 0; i < 100; i++ {
-		sup.NewChild(ALWAYS_RESTART, simpleLoopWithPanic, i)
+	num := 500
+
+	for i := 0; i < num; i++ {
+		sup.NewChild(ALWAYS_RESTART, simpleLoopWithPanic, 5)
 	}
 
-	for i := 0; i < 100; i++ {
-		sup.NewChild(ERROR_RESTART, simpleLoop, i)
+	for i := 0; i < num; i++ {
+		sup.NewChild(ERROR_RESTART, simpleLoop, 5)
 	}
 
-	time.Sleep(2 * time.Second)
+	time.Sleep(3 * time.Second)
 
 	total, running, stopped, restarting := sup.Stats()
 
 	sup.Stop()
 
 	fmt.Printf("Total: %d, Running: %d, Stopped: %d, Restarting: %d\n", total, running, stopped, restarting)
 
-	if stopped != 100 || restarting+running != 100 {
+	if stopped != num || restarting+running != num {
 		t.Error("has children status failed")
 	}
 }