添加grpool示例

geg/os/grpool/grpool1.go

@@ -14,14 +14,12 @@ func job() {
 func main() {
     grpool.SetSize(10)
     for i := 0; i < 1000; i++ {
-        grpool.Add(func() {
-            job()
-        })
+        grpool.Add(job)
     }
     gtime.SetInterval(2*time.Second, func() bool {
         fmt.Println("size:", grpool.Size())
         fmt.Println("jobs:", grpool.Jobs())
         return true
     })
-    time.Sleep(5000*time.Second)
+    select {}
 }

geg/os/grpool/grpool2.go

@@ -0,0 +1,19 @@
+package main
+
+import (
+    "fmt"
+    "sync"
+    "gitee.com/johng/gf/g/os/grpool"
+)
+
+func main() {
+    wg := sync.WaitGroup{}
+    for i := 0; i < 10; i++ {
+        wg.Add(1)
+        grpool.Add(func() {
+            fmt.Println(i)
+            wg.Done()
+        })
+    }
+    wg.Wait()
+}

geg/os/grpool/grpool3.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+    "fmt"
+    "sync"
+)
+
+func main() {
+    wg := sync.WaitGroup{}
+    for i := 0; i < 10; i++ {
+        wg.Add(1)
+        go func(v int){
+            fmt.Println(v)
+            wg.Done()
+        }(i)
+    }
+    wg.Wait()
+}

geg/os/grpool/grpool4.go

@@ -0,0 +1,20 @@
+package main
+
+import (
+    "fmt"
+    "sync"
+    "gitee.com/johng/gf/g/os/grpool"
+)
+
+func main() {
+    wg := sync.WaitGroup{}
+    for i := 0; i < 10; i++ {
+        wg.Add(1)
+        v := i
+        grpool.Add(func() {
+            fmt.Println(v)
+            wg.Done()
+        })
+    }
+    wg.Wait()
+}