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

Merge pull request 'fix' (#12) from master into dev

Browse Source 
Reviewed-on: #12
This commit is contained in:
emmatveev 2025-01-06 13:21:09 +03:00
commit b17ed7e7a9
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
app/routers/take.go
View File

@ -1,8 +1,11 @@
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 {
@ -17,17 +20,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
} }