chore: update all example

Signed-off-by: Bo-Yi Wu <[email protected]>

Author: appleboy

_example/example01/go.mod

@@ -0,0 +1,11 @@
+module example
+
+go 1.16
+
+require (
+	github.com/golang-queue/queue v0.0.7-0.20210820051048-3cc52a575c1c // indirect
+	github.com/golang/protobuf v1.5.2 // indirect
+	github.com/nats-io/nats-server/v2 v2.3.2 // indirect
+	github.com/nsqio/go-nsq v1.0.8 // indirect
+	google.golang.org/protobuf v1.27.1 // indirect
+)

_example/simple/example01/go.sum renamed to _example/example01/go.sum

@@ -1,6 +1,8 @@
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/golang-queue/queue v0.0.6 h1:TLd0lSM7uNgXXj7SXSMfyaZUwRgbOu9tq6UfZXXELnA=
 github.com/golang-queue/queue v0.0.6/go.mod h1:IeIGBO1largDrFEaxDgIckoAFIUTn0eolTQris8bm08=
+github.com/golang-queue/queue v0.0.7-0.20210820051048-3cc52a575c1c h1:RX+BTPGEITf2Jy/B1X5Qu+l8yGdGR3Z/Cx/9IM3MffI=
+github.com/golang-queue/queue v0.0.7-0.20210820051048-3cc52a575c1c/go.mod h1:JS5tYJacahCjafcplU5idNLX2vkYioqh6wEDX5o9Nms=
 github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
 github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
 github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=

_example/simple/example01/main.go renamed to _example/example01/main.go

@@ -8,7 +8,6 @@ import (
 	"time"
 
 	"github.com/golang-queue/queue"
-	"github.com/golang-queue/queue/simple"
 )
 
 type job struct {
@@ -29,9 +28,9 @@ func main() {
 	rets := make(chan string, taskN)
 
 	// define the worker
-	w := simple.NewWorker(
-		simple.WithQueueNum(taskN),
-		simple.WithRunFunc(func(ctx context.Context, m queue.QueuedMessage) error {
+	w := queue.NewConsumer(
+		queue.WithQueueSize(taskN),
+		queue.WithFn(func(ctx context.Context, m queue.QueuedMessage) error {
 			v, ok := m.(*job)
 			if !ok {
 				if err := json.Unmarshal(m.Bytes(), &v); err != nil {

_example/example02/go.mod

@@ -0,0 +1,11 @@
+module example
+
+go 1.16
+
+require (
+	github.com/golang-queue/queue v0.0.7-0.20210820051048-3cc52a575c1c
+	github.com/golang/protobuf v1.5.2 // indirect
+	github.com/nats-io/nats-server/v2 v2.3.2 // indirect
+	github.com/nsqio/go-nsq v1.0.8 // indirect
+	google.golang.org/protobuf v1.27.1 // indirect
+)

_example/simple/example02/go.sum renamed to _example/example02/go.sum

@@ -2,6 +2,8 @@ github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/golang-queue/queue v0.0.6 h1:TLd0lSM7uNgXXj7SXSMfyaZUwRgbOu9tq6UfZXXELnA=
 github.com/golang-queue/queue v0.0.6/go.mod h1:IeIGBO1largDrFEaxDgIckoAFIUTn0eolTQris8bm08=
+github.com/golang-queue/queue v0.0.7-0.20210820051048-3cc52a575c1c h1:RX+BTPGEITf2Jy/B1X5Qu+l8yGdGR3Z/Cx/9IM3MffI=
+github.com/golang-queue/queue v0.0.7-0.20210820051048-3cc52a575c1c/go.mod h1:JS5tYJacahCjafcplU5idNLX2vkYioqh6wEDX5o9Nms=
 github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
 github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
 github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=

_example/simple/example02/main.go renamed to _example/example02/main.go

@@ -7,16 +7,15 @@ import (
 	"time"
 
 	"github.com/golang-queue/queue"
-	"github.com/golang-queue/queue/simple"
 )
 
 func main() {
 	taskN := 100
 	rets := make(chan string, taskN)
 
 	// define the worker
-	w := simple.NewWorker(
-		simple.WithQueueNum(taskN),
+	w := queue.NewConsumer(
+		queue.WithQueueSize(taskN),
 	)
 
 	// define the queue