From b35c9e43822ca44029c63d9379b7ac09bdcf89d8 Mon Sep 17 00:00:00 2001
From: Gordon <46924906+FGadvancer@users.noreply.github.com>
Date: Fri, 19 Apr 2024 12:22:14 +0800
Subject: [PATCH] fix: callback update.

---
 pkg/util/memAsyncQueue/queue.go | 2 --
 1 file changed, 2 deletions(-)

diff --git a/pkg/util/memAsyncQueue/queue.go b/pkg/util/memAsyncQueue/queue.go
index c033116a9..2d1fd7003 100644
--- a/pkg/util/memAsyncQueue/queue.go
+++ b/pkg/util/memAsyncQueue/queue.go
@@ -2,7 +2,6 @@ package memAsyncQueue
 
 import (
 	"errors"
-	"fmt"
 	"sync"
 	"time"
 )
@@ -39,7 +38,6 @@ func (mq *MemoryQueue) Initialize(workerCount int, bufferSize int) {
 		go func(workerID int) {
 			defer mq.wg.Done()
 			for task := range mq.taskChan {
-				fmt.Printf("Worker %d: Executing task\n", workerID)
 				task() // Execute the function
 			}
 		}(i)