add workpool

README.md

@@ -17,11 +17,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.New(10)     //Set the maximum number of threads，设置最大线程数
+	wp := workpool.New(10)     //Set the maximum number of threads，设置最大线程数
 	for i := 0; i < 20; i++ { //开启20个请求
 		ii := i
 		wp.Do(func() error {
@@ -47,11 +47,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.New(10)             //Set the maximum number of threads，设置最大线程数
+	wp := workpool.New(10)             //Set the maximum number of threads，设置最大线程数
 	for i := 0; i < 20; i++ { 
 		ii := i
 		wp.Do(func() error {
@@ -84,11 +84,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.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.Do(func() error {
@@ -116,11 +116,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.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 {

README_cn.md

@@ -15,11 +15,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.New(10)             //设置最大线程数
+	wp := workpool.New(10)             //设置最大线程数
 	for i := 0; i < 20; i++ { //开启20个请求
 		ii := i
 		wp.Do(func() error {
@@ -45,11 +45,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.New(10)             //设置最大线程数
+	wp := workpool.New(10)             //设置最大线程数
 	for i := 0; i < 20; i++ { //开启20个请求
 		ii := i
 		wp.Do(func() error {
@@ -82,11 +82,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.New(5)              //设置最大线程数
+	wp := workpool.New(5)              //设置最大线程数
 	for i := 0; i < 10; i++ { //开启20个请求
 		//	ii := i
 		wp.Do(func() error {
@@ -114,11 +114,11 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 )
 
 func main() {
-	wp := workerpool.New(5)              //设置最大线程数
+	wp := workpool.New(5)              //设置最大线程数
 	for i := 0; i < 10; i++ { //开启20个请求
 		ii := i
 		wp.DoWait(func() error {

main.go

@@ -3,12 +3,12 @@ package main
 import (
 	"fmt"
 
-	"github.com/xxjwxc/gowp/workerpool"
+	"github.com/xxjwxc/gowp/workpool"
 	"github.com/xxjwxc/public/errors"
 )
 
 func tets() {
-	wp := workerpool.New(5) //设置最大线程数
+	wp := workpool.New(5) //设置最大线程数
 	wp.DoWait(func() error {
 		for j := 0; j < 10; j++ {
 			fmt.Println(fmt.Sprintf("%v->\t%v", 000, j))

workerpool/def.go → workpool/def.go

@@ -1,4 +1,4 @@
-package workerpool
+package workpool
 
 import (
 	"sync"

workerpool/workerpool.go → workpool/workpool.go

@@ -1,13 +1,11 @@
-package workerpool
+package workpool
 
 import (
 	"context"
 	"sync/atomic"
 	"time"
 
 	"github.com/xxjwxc/public/myqueue"
-
-	"github.com/xxjwxc/public/mylog"
 )
 
 //New 注册工作池，并设置最大并发数
@@ -127,7 +125,7 @@ func (p *WorkerPool) loop(maxWorkersCount int) {
 						case <-ct.Done():
 							p.errChan <- ct.Err()
 							//if atomic.LoadInt32(&p.closed) != 1 {
-							mylog.Error(ct.Err())
+							//mylog.Error(ct.Err())
 							atomic.StoreInt32(&p.closed, 1)
 							cancel()
 						case <-closed:
@@ -141,7 +139,7 @@ func (p *WorkerPool) loop(maxWorkersCount int) {
 					select {
 					case p.errChan <- err:
 						//if atomic.LoadInt32(&p.closed) != 1 {
-						mylog.Error(err)
+						//mylog.Error(err)
 						atomic.StoreInt32(&p.closed, 1)
 					default:
 					}

workerpool/workerpool_test.go → workpool/workpool_test.go

@@ -1,4 +1,4 @@
-package workerpool
+package workpool
 
 import (
 	"fmt"