الرئيسية / Concurrency / التزامن المنظّم
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());
}
هل ترى مشكلة في هذا الكود؟ أخبرنا.
لماذا يتفوق الأسلوب الحديث
🛡️

لا تسريب للخيوط

تكتمل جميع المهام المتفرعة قبل إغلاق النطاق.

⚡

فشل سريع

ShutdownOnFailure يلغي المهام الشقيقة إذا فشلت إحداها.

📐

بنية واضحة

دورة حياة المهمة تتطابق مع النطاق المعجمي في الكود.

الأسلوب القديم
إدارة دورة حياة الخيوط يدوياً
الأسلوب الحديث
StructuredTaskScope
منذ JDK
25
الصعوبة
متقدم
دعم JDK
التزامن المنظّم
معاينة

معاينة في JDK 25 (المعاينة الخامسة، JEP 505). يتطلب --enable-preview.

كيف يعمل

يعامل التزامن المنظّم مجموعةً من المهام المتزامنة كعملية واحدة. إذا فشلت أي مهمة فرعية أُلغيت الأخرى. يضمن النطاق عدم تسريب الخيوط ويوفر علاقات واضحة بين الوالد والطفل.

توثيق ذو صلة
Structured Concurrency (JEP 499) ↗ StructuredTaskScope ↗
أنماط ذات صلة
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+ →
Concurrency متقدم

Scoped values

Java 8
static final ThreadLocal<User> CURRENT =
    new ThreadLocal<>();
void handle(Request req) {
    CURRENT.set(authenticate(req));
    try { process(); }
    finally { CURRENT.remove(); }
}
Java 25
static final ScopedValue<User> CURRENT =
    ScopedValue.newInstance();
void handle(Request req) {
    ScopedValue.where(CURRENT,
        authenticate(req)
    ).run(this::process);
}
مرر للرؤية الحديث ←
JDK 25+ →
Concurrency متقدم

Stable values

Java 8
private volatile Logger logger;
Logger getLogger() {
    if (logger == null) {
        synchronized (this) {
            if (logger == null)
                logger = createLogger();
        }
    }
    return logger;
}
Java 25 (Preview)
private final StableValue<Logger> logger =
    StableValue.of(this::createLogger);

Logger getLogger() {
    return logger.get();
}
مرر للرؤية الحديث ←
JDK 25+ →
مشاركة 𝕏 🦋 in ⬡