Bài học

Phân tích cách khởi chạy và kết hợp các tính toán bất đồng bộ với CompletableFuture: cách khởi động tác vụ qua supplyAsync và runAsync, sự khác nhau giữa các trình xử lý thenApply, thenAccept, thenRun, và khi nào nên chọn các phiên bản bất đồng bộ thenApplyAsync/ thenAcceptAsync/ thenRunAsync. Sẽ bàn về luồng thực thi ( ForkJoinPool hoặc Executor của bạn), kiểu kết quả ( CompletableFuture<T>, CompletableFuture<Void>) và các lỗi thường gặp: gọi chặn get()/ join(), lỗi không được xử lý nếu thiếu exceptionally/ handle/ whenComplete, cũng như việc cố gắng dùng kết quả bên trong thenRun.

Cách chạy song song các tác vụ và hợp nhất kết quả bằng CompletableFuture: hợp nhất hai kết quả qua thenCombine/ thenCombineAsync, chờ một tập tác vụ bằng allOf, phản hồi theo kết quả nhanh nhất bằng anyOf. Chúng ta sẽ xem xét chữ ký (signature), các ví dụ thực tiễn với supplyAsync, xử lý không chặn ( thenAccept, thenRun), cũng như các điểm tinh tế về lỗi và cách xử lý chúng ( exceptionally, handle, whenComplete). Cuối cùng — bảng so sánh gọn nhẹ các phương thức.

Cách bắt và xử lý ngoại lệ một cách an toàn trong các chuỗi CompletableFuture: phân tích vai trò của exceptionally (trả về giá trị dự phòng khi có lỗi), handle (bộ xử lý tổng quát cho cả thành công/lỗi) và whenComplete (hành động phụ mà không thay đổi kết quả). Thảo luận vì sao việc gọi trực tiếp get()/ join() lại bọc nguyên nhân vào ExecutionException/ CompletionException, cách kết hợp các bước ( thenApply, thenAccept) và những lỗi thường gặp cần tránh.

Cách “ghép” đúng các bước bất đồng bộ trong CompletableFuture bằng thenCompose và khi nào chỉ cần thenApply; cách và lý do kết nối pool luồng riêng qua ExecutorService (thay cho ForkJoinPool.commonPool()); cách bảo vệ chuỗi khỏi “chờ mãi mãi” bằng orTimeout và completeOnTimeout. Cuối cùng — ví dụ thực hành với Executor tùy chỉnh, thenCompose và timeout, cùng các lỗi thường gặp và cách xử lý.