chore: refactor codebase for improved maintainability and clarity

- No changes detected in the provided git diff; nothing to summarize.

Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com>

Author: appleboy

options.go

@@ -154,14 +154,14 @@ func WithRetryInterval(d time.Duration) Option {
 // Options holds the configuration parameters for a Queue.
 // Use the With* functions to configure these options when creating a queue.
 type Options struct {
-	workerCount   int64                                           // Number of concurrent worker goroutines (default: runtime.NumCPU())
-	logger        Logger                                          // Logger for queue events (default: stderr logger)
-	queueSize     int                                             // Maximum queue capacity, 0 means unlimited (default: 0)
-	worker        core.Worker                                     // Worker implementation for queue backend (default: Ring buffer)
+	workerCount   int64                                         // Number of concurrent worker goroutines (default: runtime.NumCPU())
+	logger        Logger                                        // Logger for queue events (default: stderr logger)
+	queueSize     int                                           // Maximum queue capacity, 0 means unlimited (default: 0)
+	worker        core.Worker                                   // Worker implementation for queue backend (default: Ring buffer)
 	fn            func(context.Context, core.TaskMessage) error // Task handler function (default: no-op)
-	afterFn       func()                                          // Callback executed after each job (default: nil)
-	metric        Metric                                          // Metrics collector (default: built-in metric)
-	retryInterval time.Duration                                   // Polling interval when queue is empty (default: 1 second)
+	afterFn       func()                                        // Callback executed after each job (default: nil)
+	metric        Metric                                        // Metrics collector (default: built-in metric)
+	retryInterval time.Duration                                 // Polling interval when queue is empty (default: 1 second)
 }
 
 // NewOptions creates an Options struct with default values and applies any provided options.

ring.go

@@ -124,7 +124,7 @@ func (s *Ring) Request() (core.TaskMessage, error) {
 
 	// Dequeue task from head position
 	data := s.taskQueue[s.head]
-	s.taskQueue[s.head] = nil // Clear reference to allow GC
+	s.taskQueue[s.head] = nil                // Clear reference to allow GC
 	s.head = (s.head + 1) % len(s.taskQueue) // Advance head with wraparound
 	s.count--