update timeout

README.md

@@ -11,9 +11,9 @@
 - Concurrency limiting goroutine pool. 
 - Limits the concurrency of task execution, not the number of tasks queued. 
 - Never blocks submitting tasks, no matter how many tasks are queued.
+- Support timeout
 - Support through security queues [queue](https://github.com/xxjwxc/public/tree/master/myqueue)
 
-- golang workpool common library
 
 ## Installation
 
@@ -140,7 +140,7 @@ import (
 )
 
 func main() {
-	wp := workpool.New(5) //Set the maximum number of threads
+	wp := workpool.New(5) // Set the maximum number of threads
 	for i := 0; i < 10; i++ { 
 		ii := i
 		wp.DoWait(func() error {
@@ -165,3 +165,38 @@ func main() {
 	fmt.Println("down")
 }
 ```
+
+### Support timeout exit
+
+```
+package main
+
+import (
+	"fmt"
+	"time"
+	"time"
+	"github.com/xxjwxc/gowp/workpool"
+)
+
+func main() {
+	wp := workpool.New(5)              // Set the maximum number of threads
+		wp.SetTimeout(time.Millisecond) // set max timeout
+	for i := 0; i < 10; i++ { 
+		ii := i
+		wp.DoWait(func() error {
+			for j := 0; j < 5; j++ {
+				fmt.Println(fmt.Sprintf("%v->\t%v", ii, j))
+				time.Sleep(1 * time.Second)
+			}
+
+			return nil
+		})
+	}
+
+	err := wp.Wait()
+	if err != nil {
+		fmt.Println(err)
+	}
+	fmt.Println("down")
+}
+```

README_cn.md

@@ -12,7 +12,7 @@
 - 无论排队多少任务，都不会阻止提交任务。
 - 通过队列支持[queue](https://github.com/xxjwxc/public/tree/master/myqueue)
 
-- golang 工作池公共库
+### golang 工作池公共库
 
 ## 安装
 
@@ -159,3 +159,38 @@ func main() {
 	fmt.Println("down")
 }
 ```
+
+### 支持超时退出
+
+```
+package main
+
+import (
+	"fmt"
+	"time"
+	"time"
+	"github.com/xxjwxc/gowp/workpool"
+)
+
+func main() {
+	wp := workpool.New(5)              // 设置最大线程数
+		wp.SetTimeout(time.Millisecond) // 设置超时时间
+	for i := 0; i < 10; i++ { // 开启20个请求
+		ii := i
+		wp.DoWait(func() error {
+			for j := 0; j < 5; j++ {
+				fmt.Println(fmt.Sprintf("%v->\t%v", ii, j))
+				time.Sleep(1 * time.Second)
+			}
+
+			return nil
+		})
+	}
+
+	err := wp.Wait()
+	if err != nil {
+		fmt.Println(err)
+	}
+	fmt.Println("down")
+}
+```

workpool/workpool_test.go

@@ -24,7 +24,10 @@ func TestWorkerPoolStart(t *testing.T) {
 		})
 	}
 
-	wp.Wait()
+	err := wp.Wait()
+	if err != nil {
+		fmt.Println(err)
+	}
 	fmt.Println("down")
 }