Ana Sayfa / Concurrency / Timer görevlerinden zamanlanmış executor'lara
Concurrency Orta

Timer görevlerinden zamanlanmış executor'lara

Sağlam zamanlanmış işler için Timer ve TimerTask'ı ScheduledExecutorService ile değiştirin.

Concurrency
Kod Karşılaştırması
✕ 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);
Bu kodda bir sorun mu gördünüz? Bize bildirin.
Modern yöntem neden daha iyi
🧵

Daha iyi izolasyon

Yapılandırılabilir bir iş parçacığı havuzu, ilgisiz zamanlamaların tek bir kırılgan worker'ı paylaşmasını önler.

🛡

Sağlam yürütme

Başarısız olan bir görev, scheduler'ın kendisini sonlandırmaz.

🎛

Kontrol edilebilir yaşam döngüsü

Future, iptal, gecikmeler ve kapatma standart executor API'lerini kullanır.

Eski Yaklaşım
Timer ve TimerTask
Modern Yaklaşım
ScheduledExecutorService
JDK'dan itibaren
5
Zorluk
Orta
JDK Desteği
Timer görevlerinden zamanlanmış executor'lara
Mevcut

JDK 5'ten (Eylül 2004) beri yaygın olarak kullanılabilir

Nasıl çalışır

Timer her görevi tek bir iş parçacığında çalıştırır, bu yüzden uzun süren bir görev diğerlerini geciktirir ve yakalanmamış bir istisna timer iş parçacığını sonlandırır. ScheduledExecutorService, executor çerçevesini kullanır, birden fazla worker'ı destekler, ScheduledFuture tanıtıcıları döndürür ve açık bir yaşam döngüsü yönetimi sağlar. Sahip bileşen, artık ihtiyaç duyulmadığında scheduler'ı kapatmalıdır.

İlgili Belgeler
ScheduledExecutorService ↗ Executors ↗
Kanıt
Kanıt kaynağını görüntüle ↗
İlgili desenler
Concurrency Başlangıç

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
Modernini görmek için üzerine gel ➜
JDK 19+ →
Concurrency Başlangıç

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)
);
Modernini görmek için üzerine gel ➜
JDK 19+ →
Concurrency İleri

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());
}
Modernini görmek için üzerine gel ➜
JDK 25+ →