self/queues-go
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix
All checks were successful
Deploy Dev / Build (pull_request) Successful in 42s
Details
Deploy Dev / Push (pull_request) Successful in 25s
Details
Deploy Dev / Deploy dev (pull_request) Successful in 5s
Details

Browse Source
This commit is contained in:
Egor Matveev 2025-01-06 13:16:22 +03:00
parent c9871c80c8
commit c6935a26e5
1 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
app/routers/take.go
View File

@ -1,11 +1,8 @@
package routers package routers
import ( import (
"fmt"
"net/http" "net/http"
tasks "queues-go/app/storage/mongo/collections" tasks "queues-go/app/storage/mongo/collections"
"queues-go/app/storage/redis"
"time"
) )
type TaskResponse struct { type TaskResponse struct {
@ -20,17 +17,17 @@ type TakeResponse struct {
func Take(r *http.Request) (interface{}, int) { func Take(r *http.Request) (interface{}, int) {
queue := r.Header.Get("queue") queue := r.Header.Get("queue")
mutex := redis.Sync.NewMutex(fmt.Sprintf("lock_queues_%s", queue)) // mutex := redis.Sync.NewMutex(fmt.Sprintf("lock_queues_%s", queue))
for { // for {
err := mutex.Lock() // err := mutex.Lock()
if err != nil { // if err != nil {
time.Sleep(time.Millisecond * 5) // time.Sleep(time.Millisecond * 5)
} else { // } else {
break // break
} // }
} // }
task, err := tasks.Take(queue) task, err := tasks.Take(queue)
mutex.Unlock() // mutex.Unlock()
if err != nil { if err != nil {
return nil, http.StatusInternalServerError return nil, http.StatusInternalServerError
} }