proto.lib

Bounded Concurrency với Semaphore

Semaphore giới hạn số lượng worker được chạy đồng thời, các worker còn lại phải chờ tới khi có slot được giải phóng.

ConcurrencyCơ bản2026-07-07
Bounded Concurrency với Semaphore

Tags

#semaphore#bounded-concurrency#rate-limiting#worker-pool#backpressure

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

Semaphore Barging vs FIFO (ai được cấp permit tiếp theo)

Semaphore barging (unfair) cho phép thread vừa tới giành permit trước cả các thread đang đợi trong hàng đợi, vì thread đó đang chạy sẵn và cache còn nóng — tối đa hoá throughput nhưng có thể khiến một thread bị đợi rất lâu; semaphore FIFO cấp permit đúng thứ tự để chặn trên latency.

#semaphore#fairness#barging#fifo
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
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