الرئيسية / Concurrency / من مهام Timer إلى المنفذات المجدولة
Concurrency متوسط

من مهام Timer إلى المنفذات المجدولة

استبدل Timer و TimerTask بـ ScheduledExecutorService للحصول على عمل مجدول أكثر قوة.

Concurrency
مقارنة الكود
✕ Timer and TimerTask 
Timer timer = new Timer("refresh-timer");
timer.scheduleAtFixedRate(new TimerTask() {
    @Override
    public void run() {
        refresh();
    }
}, 0, 60_000);
✓ ScheduledExecutorService 
ScheduledExecutorService scheduler =
        Executors.newScheduledThreadPool(2);

scheduler.scheduleAtFixedRate(
        this::refresh, 0, 1, TimeUnit.MINUTES);
هل ترى مشكلة في هذا الكود؟ أخبرنا.
لماذا يتفوق الأسلوب الحديث
🧵

عزل أفضل

يمنع تجمع الخيوط القابل للتهيئة الجداول غير المرتبطة من مشاركة عامل واحد هش.

🛡

تنفيذ قوي

فشل مهمة واحدة لا ينهي المجدول نفسه.

🎛

دورة حياة قابلة للتحكم

تستخدم الـ Futures والإلغاء والتأخيرات والإيقاف واجهات برمجة تطبيقات المنفذ القياسية.

الأسلوب القديم
Timer و TimerTask
الأسلوب الحديث
ScheduledExecutorService
منذ JDK
5
الصعوبة
متوسط
دعم JDK
من مهام Timer إلى المنفذات المجدولة
متاح

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

كيف يعمل

ينفذ Timer كل مهمة على خيط واحد، لذا فإن مهمة طويلة الأمد تؤخر المهام الأخرى، ويؤدي استثناء غير معالج إلى إنهاء خيط المؤقت. يستخدم ScheduledExecutorService إطار عمل المنفذات، ويدعم عدة عمال، ويعيد مقابض ScheduledFuture، ويوفر إدارة صريحة لدورة الحياة. يجب على المكوّن المالك إيقاف المجدول عند عدم الحاجة إليه.

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

Thread.sleep with Duration

Java 8
// What unit is 5000? ms? us?
Thread.sleep(5000);

// 2.5 seconds: math required
Thread.sleep(2500);
Java 19+
Thread.sleep(
    Duration.ofSeconds(5)
);
Thread.sleep(
    Duration.ofMillis(2500)
);
مرر للرؤية الحديث ←
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+ →