chore(benchmark): add performance benchmark.

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

Author: appleboy

.github/workflows/go.yml

@@ -58,6 +58,9 @@ jobs:
       - name: Run Tests
         run: |
           go test -v -covermode=atomic -coverprofile=coverage.out
+
+      - name: Run Benchmark
+        run: |
           go test -v -run=^$ -benchmem -bench .
 
       - name: Upload coverage to Codecov

benchmark_test.go

@@ -3,6 +3,10 @@ package queue
 import (
 	"context"
 	"testing"
+	"time"
+
+	"github.com/golang-queue/queue/core"
+	"github.com/golang-queue/queue/job"
 )
 
 func BenchmarkQueueTask(b *testing.B) {
@@ -27,3 +31,49 @@ func BenchmarkQueue(b *testing.B) {
 		_ = q.Queue(m)
 	}
 }
+
+func BenchmarkConsumerPayload(b *testing.B) {
+	b.ReportAllocs()
+
+	task := &job.Message{
+		Timeout: 100 * time.Millisecond,
+		Payload: []byte(`{"timeout":3600000000000}`),
+	}
+	w := NewConsumer(
+		WithFn(func(ctx context.Context, m core.QueuedMessage) error {
+			return nil
+		}),
+	)
+
+	q, _ := NewQueue(
+		WithWorker(w),
+	)
+
+	for n := 0; n < b.N; n++ {
+		_ = q.run(task)
+	}
+}
+
+func BenchmarkConsumerTask(b *testing.B) {
+	b.ReportAllocs()
+
+	task := &job.Message{
+		Timeout: 100 * time.Millisecond,
+		Task: func(_ context.Context) error {
+			return nil
+		},
+	}
+	w := NewConsumer(
+		WithFn(func(ctx context.Context, m core.QueuedMessage) error {
+			return nil
+		}),
+	)
+
+	q, _ := NewQueue(
+		WithWorker(w),
+	)
+
+	for n := 0; n < b.N; n++ {
+		_ = q.run(task)
+	}
+}