Thread safety of take!, put!
@seancorfield đang làm issue này rồi.
Từ ngày 2/9/2025.
Đánh giá
Issue này chưa được đánh giá.
Mô tả
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.
- Ngôn ngữ chính
- Clojure
- Star
- 407
- Fork
- 30
- Chỉ số merge pull request
- Không có pull request nào được merge trong 30 ngày
Chuẩn bị môi trường
Dự án này không cung cấp dev container, Dockerfile hay hướng dẫn đóng góp, nên bạn cần tự thiết lập môi trường: hãy bắt đầu từ README và xem hướng dẫn đóng góp lần đầu của chúng tôi để biết các bước chung.
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của clj-commons/durable-queue
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 30/100
clj-commons/durable-queue#31 ·
-
Slabs can grow larger than max-queue-sizeCó thể làm lại được @seancorfield đã nhận 409 ngày trước và không có pull request nào đang mở. Đang mởneeds analysis
clj-commons/durable-queue#18 · 1 bình luận · 1 người được giao ·
-
When can a statistic be negative?Có thể làm lại được @seancorfield đã nhận 409 ngày trước và không có pull request nào đang mở. Đang mởneeds analysis
clj-commons/durable-queue#12 · 6 bình luận · 1 người được giao ·
-
calling complete! on already completed task messes up statsCó thể làm lại được @seancorfield đã nhận 409 ngày trước và không có pull request nào đang mở. Đang mởneeds analysis
clj-commons/durable-queue#3 · 2 bình luận · 1 người được giao ·
Tất cả issue của clj-commons/durable-queue
Issue tương tự
-
to-calcit-data 查询合同漏列保留字符串选项 / Missing existing string-preserving argument in public contractĐang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
calcit-lang/calcit#2151 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
worker/start rejects middleware supplied as a VarCó thể đã có người làm @rajp152k đã nhận 1 ngày trước. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 75/100
-
Profiler (Remotery) leaks a socket for every connection that fails the WebSocket handshakeCó thể đã có người làm @rthery đã nhận 1 ngày trước. Đang mởtriage
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
Maintainer thường phản hồi trong vòng 1 ngày
-
IOP nitrate needs triage
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 66/100
Maintainer thường phản hồi trong vòng 1 ngày
-
category:tooling
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 62/100
Maintainer thường phản hồi trong vòng 1 ngày