fix: callback update.

1 year ago · b35c9e4382
parent e82fd5a95e
commit b35c9e4382
1 changed files with 0 additions and 2 deletions
--- 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)