الرئيسية / Concurrency / من الإنهاء غير الآمن للخيوط إلى الإلغاء التعاوني
Concurrency متقدم

من الإنهاء غير الآمن للخيوط إلى الإلغاء التعاوني

استبدل Thread.stop() والأعلام المشتركة المؤقتة بإلغاء مهام واعٍ بالمقاطعة.

Concurrency Async Programming
مقارنة الكود
✕ Forced thread termination 
Thread worker = new Thread(this::runTask);
worker.start();

// May stop the thread while shared state is inconsistent.
worker.stop();
✓ Future cancellation 
Future<?> worker = executor.submit(this::runTask);

// Requests interruption; the task must cooperate.
worker.cancel(true);
هل ترى مشكلة في هذا الكود؟ أخبرنا.
لماذا يتفوق الأسلوب الحديث
🛡

يحافظ على الثوابت

تتوقف المهام فقط عند مسارات الكود المصممة للإلغاء.

🧩

تحكم موحّد

يمثّل Future التنفيذ والاكتمال والإلغاء معاً.

🔗

قابل للتركيب

تعمل المقاطعة مع قوائم الانتظار المحظورة والأقفال والمنفذات والخيوط الافتراضية.

الأسلوب القديم
Thread.stop()
الأسلوب الحديث
Future.cancel(true)
منذ JDK
5
الصعوبة
متقدم
دعم JDK
من الإنهاء غير الآمن للخيوط إلى الإلغاء التعاوني
متاح

تتوفر Future وExecutorService منذ JDK 5 (سبتمبر 2004).

كيف يعمل

يمكن لـ Thread.stop() إنهاء الكود بينما يمتلك مراقبات (monitors) أو أثناء تحديث حالة مشتركة، مما يترك الكائنات تالفة. الإلغاء الحديث تعاوني: ألغِ الـ Future بالمقاطعة، وانشر InterruptedException حيثما أمكن، واستعد حالة المقاطعة عندما لا يمكن نشرها، وصمّم المهمة للوصول إلى نقاط إلغاء آمنة.

توثيق ذو صلة
Future ↗ Thread.stop() deprecation ↗
إثبات
عرض كود الإثبات ↗
أنماط ذات صلة
Concurrency مبتدئ

ExecutorService auto-close

Java 8
ExecutorService exec =
    Executors.newCachedThreadPool();
try {
    exec.submit(task);
} finally {
    exec.shutdown();
    exec.awaitTermination(
        1, TimeUnit.MINUTES);
}
Java 19+
try (var exec =
        Executors.newCachedThreadPool()) {
    exec.submit(task);
}
// auto shutdown + await on close
مرر للرؤية الحديث ←
JDK 19+ →
Concurrency متقدم

Structured concurrency

Java 8
ExecutorService exec =
    Executors.newFixedThreadPool(2);
Future<User> u = exec.submit(this::fetchUser);
Future<Order> o = exec.submit(this::fetchOrder);
try {
    return combine(u.get(), o.get());
} finally { exec.shutdown(); }
Java 25 (Preview)
try (var scope = new StructuredTaskScope
        .ShutdownOnFailure()) {
    var u = scope.fork(this::fetchUser);
    var o = scope.fork(this::fetchOrder);
    scope.join().throwIfFailed();
    return combine(u.get(), o.get());
}
مرر للرؤية الحديث ←
JDK 25+ →
Concurrency مبتدئ

Virtual threads

Java 8
Thread thread = new Thread(() -> {
    System.out.println("hello");
});
thread.start();
thread.join();
Java 21+
Thread.startVirtualThread(() -> {
    IO.println("hello");
}).join();
مرر للرؤية الحديث ←
JDK 21+ →