كيف يساعد إطار العمل Executor و CompletableFuture في العمل غير المتزامن؟

Question

Accepted Answer

إطار العمل **Executor** يدير مجموعات من الخيوط (threads) بحيث تقدم *مهام* بدلاً من إنشاء خيوط يدويًا، و**`CompletableFuture`** ينسق العمليات غير المتزامنة بطريقة إعلانية (declaratively). معًا، هما الطريقة الحديثة للعمل المتزامن/غير المتزامن في Java — مما يتجنب تكلفة وتعقيد إدارة الخيوط الخام. ## مشكلة الخيوط الخام ```java // ❌ creating a thread per task is expensive and unbounded → can exhaust resources for (Task t : tasks) { new Thread(() -> process(t)).start(); // 10,000 tasks → 10,000 threads → crash } ``` ## ExecutorService — مجموعات الخيوط المُدارة ```java // ✅ a fixed pool reuses a bounded set of threads for many tasks ExecutorService executor = Executors.newFixedThreadPool(10); Future future = executor.submit(() -> compute()); // submit a task Integer result = future.get(); // blocks until the result is ready executor.shutdown(); // stop accepting tasks; let running ones finish ``` يفصل `ExecutorService` بين *ما* (المهام) و *كيف* (إدارة الخيوط) — فهو يعيد استخدام مجموعة محدودة من الخيوط، مما يمنع استنزاف الموارد والعلوية المرتبطة بإنشاء خيوط مستمر. ## قيود Future ```java Future f = executor.submit(task); f.get(); // ❌ BLOCKS the calling thread; can't chain/combine without blocking ``` `Future.get()` يحجب (blocks)، ولا يمكنك بسهولة ربط العمليات المعتمدة أو دمج النتائج — وهذا بالضبط ما يصلحه `CompletableFuture`. ## CompletableFuture — غير متزامن يمكن تركيبه ```java CompletableFuture.supplyAsync(() -> fetchUser(id)) // run async, returns a value .thenApply(user -> user.getName()) // transform the result (non-blocking) .thenApply(String::toUpperCase) .thenAccept(name -> System.out.println(name)) // consume the final result .exceptionally(ex -> { log(ex); return null; }); // handle errors in the chain ``` `CompletableFuture` يتيح لك بناء **خطوط معالجة غير حجزية** — تحويل (`thenApply`)، ربط استدعاءات غير متزامنة معتمدة (`thenCompose`)، ومعالجة الأخطاء (`exceptionally`) — دون حجز الخيوط. ## دمج عمليات غير متزامنة متعددة ```java // run two independent async calls in PARALLEL and combine their results CompletableFuture userF = CompletableFuture.supplyAsync(() -> fetchUser(id)); CompletableFuture orderF = CompletableFuture.supplyAsync(() -> fetchOrder(id)); userF.thenCombine(orderF, (user, order) -> buildProfile(user, order)) .thenAccept(profile -> render(profile)); // wait for many to complete CompletableFuture.allOf(f1, f2, f3).join(); // all done ``` `thenCombine` و `allOf` و `anyOf` ينسقون مهام غير متزامنة متعددة بأناقة — تشغيل العمل المستقل بالتوازي ودمج النتائج. ## لماذا يهم إطار العمل Executor و CompletableFuture هما **الطريقة الحديثة والصحيحة** للتعامل مع التزامن والعمل غير المتزامن في Java، مما يحل محل إدارة الخيوط اليدوية التي عرضة للأخطاء. مجموعات الخيوط (ExecutorService) تتجنب استنزاف الموارد والعلوية المرتبطة بإنشاء خيط لكل مهمة — وهو أمر أساسي للخوادم القابلة للتوسع. يحل CompletableFuture قيد Future بالحجز بتفعيل **خطوط معالجة قابلة للتركيب وغير حجزية** التي تربط وتحول وتدمج وتتعامل مع الأخطاء في العمليات غير المتزامنة بطريقة إعلانية — وهو أمر حاسم لخدمات ربط الإدخال/الإخراج الفعالة التي يجب أن تنسق استدعاءات متزامنة كثيرة (قاعدة بيانات، API، الخدمات الدقيقة). فهم هذه (بدلاً من الخيوط الخام و Futures الحجزية) أساسي لبناء تطبيقات Java متزامنة فعالة وقابلة للتوسع، وهو كفاءة أساسية على مستوى كبار المهندسين.