Compare commits

..

2 Commits

Author SHA1 Message Date
a564621d80 Merge pull request 'fix' (#11) from master into dev
Reviewed-on: #11
2025-01-06 13:16:39 +03:00
Egor Matveev
c6935a26e5 fix
All checks were successful
Deploy Dev / Build (pull_request) Successful in 42s
Deploy Dev / Push (pull_request) Successful in 25s
Deploy Dev / Deploy dev (pull_request) Successful in 5s
2025-01-06 13:16:22 +03:00

View File

@ -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
}