Using `ScheduledExecutorService` for timeouts
Maintainer thường phản hồi trong vòng 1 ngày
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 5/5
- Thời gian dự kiến
- Hơn một tuần
- Mức phù hợp với người mới
- 25/100
Hướng nghiên cứu
Bắt đầu bằng cách xác định thao tác timeout và vòng đời của runtime hoặc scope, thành phần sẽ chịu trách nhiệm lập lịch. So sánh race condition hiện tại của thread đang ngủ với ScheduledExecutorService và cách tiếp cận IdleStateHandler được liên kết của Netty; issue không định nghĩa các tiêu chí nghiệm thu cho hiệu năng, việc hủy hoặc quyền sở hữu runtime.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
Currently, the timeout operation is implemented by racing given operation with a sleeping thread (BTW a similar approach is used in Cats Effect).
I was wondering if we could leverage a ScheduledExecutorService instead. It operates on a single threaded, which schedules and starts actual tasks. Netty uses this mechanism for timeouts in its IdleStateHandler. A scheduled task starts, emits an event and ends immediately. Then, Netty's internals handle the event in order to abort communication if a timeout occured.
In case of Ox, a scheduled task would start on a virtual thread (see hints in this Stack Overflow discussion). It would then call cancelation of the fork that's wrapped with timeout.
I don't know if such a solution will be more performant than racing with a sleeping thread, but I'm leaving this idea here for consideration. One certain issue is that the single-threaded pool for scheduling doesn't sound like something we want to create for each scope, but rather like a "runtime" that needs passing around.
- Ngôn ngữ chính
- Scala
- Star
- 526
- Fork
- 37
- Merge trung bình
- 10 giờ 15 phút
- Pull request đã merge (30 ngày)
- 19
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 softwaremill/ox
-
Flow.fromPublisher: allow releasing elements which are buffered but not emittedCó thể đã có người làm @adamw đã nhận 11 ngày trước. Đang mở
Độ khó 4/5 3-5 ngày Mức phù hợp với người mới 30/100
softwaremill/ox#528 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 45/100
softwaremill/ox#469 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 25/100
softwaremill/ox#366 · 7 bình luận ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 25/100
softwaremill/ox#311 · 2 bình luận ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 30/100
softwaremill/ox#201 ·
Maintainer thường phản hồi trong vòng 1 ngày
Tất cả issue của softwaremill/ox
Issue tương tự
-
Độ khó 1/5 1-3 giờ Mức phù hợp với người mới 91/100
com-vitthalmirji/toon4s#117 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 75/100
propensive/soundness#2294 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
area:scale audit priority:P2
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 76/100
KD5UJC-XYZ/scarab#231 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100
SpinalHDL/VexiiRiscv#198 ·
Maintainer thường phản hồi trong vòng 3 ngày
-
nativeLink relinks every build: IO.write leaves stale trailing bytes in build-checksumCó thể đã có người làm @kimmoeklund đã 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 78/100
scala-native/scala-native#5111 ·
Maintainer thường phản hồi trong vòng 1 ngày