الرئيسية / Concurrency / تحويل طوابير wait و notify إلى BlockingQueue
Concurrency متوسط

تحويل طوابير wait و notify إلى BlockingQueue

استبدل تنسيق المنتج-المستهلك المكتوب يدوياً باستخدام BlockingQueue.

Concurrency
مقارنة الكود
✕ Manual wait and notify 
synchronized (queue) {
    while (queue.isEmpty()) {
        queue.wait();
    }
    Job job = queue.removeFirst();
    process(job);
}
✓ BlockingQueue 
BlockingQueue<Job> queue = new LinkedBlockingQueue<>();

Job job = queue.take();
process(job);
هل ترى مشكلة في هذا الكود؟ أخبرنا.
لماذا يتفوق الأسلوب الحديث
🛡

تنسيق أكثر أماناً

يتولى الطابور القفل والإشارة الشرطية.

👁

نية واضحة

تعبّر put() و take() مباشرة عن سلوك المنتج-المستهلك.

🎛

سياسات مدمجة

اختر سعة محدودة أو العدالة أو المهلات أو العمليات غير الحاجزة.

الأسلوب القديم
wait و notify يدوياً
الأسلوب الحديث
BlockingQueue
منذ JDK
5
الصعوبة
متوسط
دعم JDK
تحويل طوابير wait و notify إلى BlockingQueue
متاح

متاح على نطاق واسع منذ JDK 5 (2004)

كيف يعمل

يتطلب كود wait/notify الصحيح مراقباً مشتركاً وحلقات شرطية وإشعارات متطابقة ومعالجة دقيقة للمقاطعة. تُغلّف BlockingQueue هذه القواعد وتوفر عمليات حاجزة ومحددة زمنياً وغير حاجزة لسير عمل المنتج-المستهلك. تبقى استدعاءات مثل put() و take() قابلة للمقاطعة.

توثيق ذو صلة
BlockingQueue ↗ LinkedBlockingQueue ↗
إثبات
عرض كود الإثبات ↗
أنماط ذات صلة
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+ →