From c6935a26e51fa8997c3e16b1221df2c5690eea4d Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Mon, 6 Jan 2025 13:16:22 +0300 Subject: [PATCH] fix --- app/routers/take.go | 23 ++++++++++------------- 1 file changed, 10 insertions(+), 13 deletions(-) diff --git a/app/routers/take.go b/app/routers/take.go index 1f3d05c..84ea8b7 100644 --- a/app/routers/take.go +++ b/app/routers/take.go @@ -1,11 +1,8 @@ package routers import ( - "fmt" "net/http" tasks "queues-go/app/storage/mongo/collections" - "queues-go/app/storage/redis" - "time" ) type TaskResponse struct { @@ -20,17 +17,17 @@ type TakeResponse struct { func Take(r *http.Request) (interface{}, int) { queue := r.Header.Get("queue") - mutex := redis.Sync.NewMutex(fmt.Sprintf("lock_queues_%s", queue)) - for { - err := mutex.Lock() - if err != nil { - time.Sleep(time.Millisecond * 5) - } else { - break - } - } + // mutex := redis.Sync.NewMutex(fmt.Sprintf("lock_queues_%s", queue)) + // for { + // err := mutex.Lock() + // if err != nil { + // time.Sleep(time.Millisecond * 5) + // } else { + // break + // } + // } task, err := tasks.Take(queue) - mutex.Unlock() + // mutex.Unlock() if err != nil { return nil, http.StatusInternalServerError }