Thread safety of take!, put!
@seancorfield ci sta già lavorando.
Dal 2/9/2025.
Valutazione
Questa issue non è ancora stata valutata.
Descrizione
Hi,
Should we consider put! and take! threadsafe?
I have one thread doing puts in bursts at regular interval, and N workers on their own respective threads consuming the queue. Sometimes I get into a situation where I have 1 in progress task and all other workers waiting on tasks while the queue keeps growing (essentially deadlocked at this point). In the code I take!, deref and mark completed tasks immediately (did that to exclude a bug on complete!).
Should I serialize the takes or is this a potential bug? I ll try to come up with a repro at work tomorrow.
I also get the occasional negative in-progress while testing:
09:22:14.938 [clojure-agent-send-off-pool-0] INFO sink.testdq - {foo {:num-slabs 1, :num-active-slabs 1, :enqueued 10947, :retried 0, :completed 10947, :in-progress -1}}
Thanks for the lib by the way, it s super useful.
- Lingua principale
- Clojure
- Stelle
- 407
- Fork
- 30
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Preparare l'ambiente
Questo progetto non fornisce container di sviluppo, Dockerfile né guida per i contributori, quindi l'ambiente è a tuo carico: parti dal suo README e consulta la nostra guida al primo contributo per i passaggi generali.
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di clj-commons/durable-queue
-
Difficoltà 5/5 Più di una settimana Idoneità per principianti 30/100
clj-commons/durable-queue#31 ·
-
Slabs can grow larger than max-queue-sizeForse di nuovo libera @seancorfield l’ha presa 411 giorni fa e non c’è nessuna pull request aperta. Apertaneeds analysis
clj-commons/durable-queue#18 · 1 commento · 1 assegnatario ·
-
When can a statistic be negative?Forse di nuovo libera @seancorfield l’ha presa 411 giorni fa e non c’è nessuna pull request aperta. Apertaneeds analysis
clj-commons/durable-queue#12 · 6 commenti · 1 assegnatario ·
-
calling complete! on already completed task messes up statsForse di nuovo libera @seancorfield l’ha presa 411 giorni fa e non c’è nessuna pull request aperta. Apertaneeds analysis
clj-commons/durable-queue#3 · 2 commenti · 1 assegnatario ·
Tutte le issue di clj-commons/durable-queue
Issue simili
-
bug
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 92/100
editor-code-assistant/eca#655 ·
I maintainer di solito rispondono entro 2 giorni
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 85/100
I maintainer di solito rispondono entro 1 giorno
-
needs triage
Difficoltà 2/5 1-3 ore Idoneità per principianti 84/100
I maintainer di solito rispondono entro 1 giorno
-
to-calcit-data 查询合同漏列保留字符串选项 / Missing existing string-preserving argument in public contractAperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
calcit-lang/calcit#2151 · 1 commento ·
I maintainer di solito rispondono entro 1 giorno
-
worker/start rejects middleware supplied as a VarForse già presa @rajp152k l’ha presa 2 giorni fa. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100