proto.lib

Fan-Out/Fan-In: Join qua bộ đếm chia sẻ

Một request nổ ra thành N subtask song song (ví dụ render 500 thumbnail); mỗi subtask hoàn tất độc lập rồi tăng nguyên tử một bộ đếm chia sẻ, subtask cuối cùng chạm ngưỡng sẽ kích hoạt continuation — với các điểm khó là subtask không bao giờ xong, retry làm đếm trùng, và worker không được block chờ chính con của nó.

MessagingNâng cao2026-08-20
Fan-Out/Fan-In: Join qua bộ đếm chia sẻ

Tags

#fan-out#fan-in#task-queue#join#atomic-counter#idempotency#deadlock

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

MessagingTrung bình

Ack sớm vs Ack muộn trong Task Queue

Ack ngay khi nhận task (early ack) khiến worker crash làm mất task vĩnh viễn vì broker đã xoá nó khỏi hàng đợi; ack sau khi xử lý xong (late ack) khiến crash làm task được redeliver, nên chỉ có late ack kết hợp task idempotent mới đảm bảo không mất việc.

#task-queue#ack#acknowledgement#prefetch
MessagingTrung bình

Sink Connector ghi idempotent bằng upsert

Một sink kết nối stream vào database phải tránh trùng lặp khi redelivery: nó tính khoá xác định cho mỗi record và ghi bằng upsert (hoặc insert kèm unique constraint), đồng thời lưu version/offset của record để một retry cũ hơn không thể ghi đè bản mới hơn.

#sink-connector#idempotency#upsert#at-least-once
MessagingTrung bình

Drain Consumer trước khi Deploy

Khi deploy, instance consumer phải dừng fetch message mới, xử lý xong phần đang giữ, commit rồi mới exit; grace period của orchestrator phải dài hơn thời gian xử lý message lâu nhất, nếu không platform sẽ kill giữa chừng và broker redeliver phần việc đó.

#graceful-shutdown#drain#deploy#sigterm