chore(options): update default capacity as zero (#100)

Author: appleboy

consumer.go

@@ -52,7 +52,7 @@ func (s *Consumer) Queue(task core.QueuedMessage) error { //nolint:stylecheck
 	if atomic.LoadInt32(&s.stopFlag) == 1 {
 		return ErrQueueShutdown
 	}
-	if s.count >= s.capacity {
+	if s.capacity > 0 && s.count >= s.capacity {
 		return errMaxCapacity
 	}
 

options.go

@@ -8,7 +8,7 @@ import (
 )
 
 var (
-	defaultQueueSize   = 4096
+	defaultCapacity    = 0
 	defaultWorkerCount = runtime.NumCPU()
 	defaultNewLogger   = NewLogger()
 	defaultFn          = func(context.Context, core.QueuedMessage) error { return nil }
@@ -87,7 +87,7 @@ type Options struct {
 func NewOptions(opts ...Option) *Options {
 	o := &Options{
 		workerCount: defaultWorkerCount,
-		queueSize:   defaultQueueSize,
+		queueSize:   defaultCapacity,
 		logger:      defaultNewLogger,
 		worker:      nil,
 		fn:          defaultFn,