package main
import (
   "fmt"
   "github.com/gogf/gf/os/grpool"
   "github.com/gogf/gf/os/gtimer"
   "sync"
   "time"
)
func main() {
   pool := grpool.New(100)
   //添加1千個任務
   for i := 0; i < 1000; i++ {
      _ = pool.Add(job)
   }
   fmt.Println("worker:", pool.Size()) //當前工作的協(xié)程數量
   fmt.Println("jobs:", pool.Jobs())   //當前池中待處理的任務數量

   gtimer.SetInterval(time.Second, func() {
      fmt.Println("worker:", pool.Size()) //當前工作的協(xié)程數
      fmt.Println("jobs:", pool.Jobs())   //當前池中待處理的任務數
   })
   //阻止進程結束
   select {}
}
//任務方法
func job() {
   time.Sleep(time.Second)
}

wg := sync.WaitGroup{}
for i := 0; i < 9; i++ {
   wg.Add(1)
   go func() {
      fmt.Println(i)
      wg.Done()
   }()
}
wg.Wait()

wg := sync.WaitGroup{}
for i := 0; i < 9; i++ {
   wg.Add(1)
   go func(v int) {
      fmt.Println(v)
      wg.Done()
   }(i)
}
wg.Wait()

wg := sync.WaitGroup{}
for i := 0; i < 9; i++ {
   wg.Add(1)
   _ = grpool.Add(func() {
      fmt.Println(i) //打印結果都是9
      wg.Done()
   })
}
wg.Wait()

wg := sync.WaitGroup{}
for i := 0; i < 9; i++ {
   wg.Add(1)
   v := i //grpoll.add() 的參數只能是不帶參數的匿名函數 因此只能以設置臨時變量的方式賦值
   _ = grpool.Add(func() {
      fmt.Println(v)
      wg.Done()
   })
}
wg.Wait()