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千個任務(wù)
   for i := 0; i < 1000; i++ {
      _ = pool.Add(job)
   }
   fmt.Println("worker:", pool.Size()) //當(dāng)前工作的協(xié)程數(shù)量
   fmt.Println("jobs:", pool.Jobs())   //當(dāng)前池中待處理的任務(wù)數(shù)量

   gtimer.SetInterval(time.Second, func() {
      fmt.Println("worker:", pool.Size()) //當(dāng)前工作的協(xié)程數(shù)
      fmt.Println("jobs:", pool.Jobs())   //當(dāng)前池中待處理的任務(wù)數(shù)
   })
   //阻止進(jìn)程結(jié)束
   select {}
}
//任務(wù)方法
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) //打印結(jié)果都是9
      wg.Done()
   })
}
wg.Wait()

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