proto.lib

Reactive Streams - Backpressure

Subscriber chủ động yêu cầu số lượng phần tử muốn nhận, giúp publisher không làm tràn ngập consumer chậm hơn.

ConcurrencyTrung bình2026-07-08
Reactive Streams - Backpressure

Tags

#reactive-streams#backpressure#publisher-subscriber#flow-control#async

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

ConcurrencyTrung bình

Channel Thay Cho Lock (Serialization qua Owner Task)

Thay vì mọi thread lock một vùng state dùng chung, một task duy nhất (owner) giữ độc quyền state đó và chỉ nhận message qua channel để đọc/sửa — biến mutual exclusion thành một hàng đợi, loại bỏ hoàn toàn khả năng deadlock giữa các lock vì chỉ còn một luồng chạy critical section.

#channel#owner-task#message-passing#serialization-point
ConcurrencyNâng cao

Cancellation Safety: hủy tác vụ giữa chừng mà không để lại nửa trạng thái

Hủy một tác vụ đang chạy tại một await point có thể để lại thế giới ở trạng thái nửa vời (một dòng đã insert, một file viết nửa chừng, một khoá đã acquire); tác vụ có thể hủy an toàn cần: thực hiện hiệu ứng bên ngoài trong một bước atomic, đăng ký cleanup chạy khi unwind, và có critical section được shield khỏi việc bị hủy — cùng kỷ luật bất biến như một transaction.

#cancellation#async#invariants#cleanup
ConcurrencyTrung bình

Bounded Mailbox: hộp thư có giới hạn buộc actor phải chọn chính sách backpressure

Một actor có mailbox không giới hạn là một memory leak trá hình; mailbox có giới hạn buộc hệ thống quyết định khi đầy — block sender (lan truyền backpressure), drop message mới nhất/cũ nhất, hoặc fail fast — và mỗi lựa chọn tạo ra một failure mode khác nhau cho toàn hệ thống.

#actor-model#mailbox#backpressure#bounded-queue