diff --git a/README.md b/README.md index 578f0d1..17bbf51 100644 --- a/README.md +++ b/README.md @@ -9,6 +9,16 @@ ### 支持最大任务数, 放到工作池里面 并等待全部完成 ``` +package main + +import ( + "fmt" + "time" + + "github.com/xxjwxc/gowp/workerpool" +) + +func main() { wp := workerpool.New(10) //设置最大线程数 for i := 0; i < 20; i++ { //开启20个请求 ii := i @@ -24,10 +34,21 @@ wp.Wait() fmt.Println("down") +} ``` ### 支持错误返回 ``` +package main + +import ( + "fmt" + "time" + + "github.com/xxjwxc/gowp/workerpool" +) + +func main() { wp := workerpool.New(10) //设置最大线程数 for i := 0; i < 20; i++ { //开启20个请求 ii := i @@ -49,11 +70,22 @@ fmt.Println(err) } fmt.Println("down") + } ``` ### 支持判断是否完成 (非阻塞) ``` +package main + +import ( + "fmt" + "time" + + "github.com/xxjwxc/gowp/workerpool" +) + +func main() { wp := workerpool.New(5) //设置最大线程数 for i := 0; i < 10; i++ { //开启20个请求 // ii := i @@ -70,11 +102,22 @@ wp.Wait() fmt.Println(wp.IsDone()) fmt.Println("down") +} ``` ### 支持同步等待结果 ``` +package main + +import ( + "fmt" + "time" + + "github.com/xxjwxc/gowp/workerpool" +) + +func main() { wp := workerpool.New(5) //设置最大线程数 for i := 0; i < 10; i++ { //开启20个请求 ii := i @@ -98,5 +141,5 @@ fmt.Println(err) } fmt.Println("down") - -``` \ No newline at end of file +} +```