ScheduledExecutorService voor terugkerende taken
Plan taken met vaste frequenties of vaste vertragingen voor polling en onderhoud op de achtergrond.
ScheduledExecutorService voor terugkerende taken is een gratis Java Academy-les op CoddyKit. Dit is les 4 van 4. Je kunt de volledige les hieronder gratis lezen en daarna in de browser praktisch oefenen met een ingebouwde code-editor en een AI-begeleider die 24/7 beschikbaar is. Deze les maakt deel uit van het leertraject Java Academy. Je voortgang wordt gesynchroniseerd op het web en in de CoddyKit-app. De cursus Java Academy bevat in totaal 4 lessen.
Waarom ScheduledExecutorService?
ScheduledExecutorService breidt ExecutorService uit met ondersteuning voor taakplanning. Het vervangt de verouderde klassen Timer/TimerTask door een planner die op een threadpool is gebaseerd en veilig met uitzonderingen omgaat.
import java.util.concurrent.*;
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
// One-shot delay
scheduler.schedule(
() -> System.out.println("Runs once after 3 seconds"),
3, TimeUnit.SECONDS
);
// Don't forget to shut down eventually:
// scheduler.shutdown();schedule: eenmalige vertraging
schedule(task, delay, unit) voert de taak één keer uit na de opgegeven vertraging. Dit werkt met zowel Runnable als Callable:
ScheduledExecutorService s = Executors.newScheduledThreadPool(1);
// Runnable:
ScheduledFuture<?> sf1 = s.schedule(
() -> System.out.println("Runnable fired!"), 2, TimeUnit.SECONDS);
// Callable:
ScheduledFuture<Integer> sf2 = s.schedule(
() -> { System.out.println("Callable fired!"); return 42; },
2, TimeUnit.SECONDS);
System.out.println(sf2.get()); // 42 (after 2 seconds)scheduleAtFixedRate
scheduleAtFixedRate(task, initialDelay, period, unit) voert de taak herhaaldelijk uit met een vaste frequentie. Als een taak langer duurt dan de periode, start de volgende uitvoering direct nadat de vorige is voltooid (zonder overlap).
ScheduledExecutorService s = Executors.newScheduledThreadPool(1);
AtomicInteger count = new AtomicInteger();
ScheduledFuture<?> sf = s.scheduleAtFixedRate(
() -> System.out.println("Tick " + count.incrementAndGet()),
0, // initial delay
1, // period
TimeUnit.SECONDS
);
Thread.sleep(5000);
sf.cancel(false); // stop after 5 ticks
s.shutdown();scheduleWithFixedDelay
scheduleWithFixedDelay(task, initialDelay, delay, unit) wacht de opgegeven vertraging NA elke voltooide taak voordat de volgende wordt gestart. Geschikt voor polling waarbij de taakduur varieert.
s.scheduleWithFixedDelay(
() -> {
System.out.println("Polling... " + Instant.now());
// variable-length polling task
},
0, // no initial delay
5, // 5-second gap AFTER each completion
TimeUnit.SECONDS
);
// Next execution = task end + 5 seconds (not task start)Vaste frequentie tegenover vaste vertraging
Belangrijk onderscheid:
- scheduleAtFixedRate: volgende start = vorige start + periode (timing zonder verschuiving)
- scheduleWithFixedDelay: volgende start = vorige voltooiing + vertraging (gegarandeerde pauze tussen uitvoeringen)
Gebruik fixedRate voor heartbeats en fixedDelay voor polling waarbij de taakduur varieert.
ScheduledFuture: annuleren
schedule/scheduleAtFixedRate/scheduleWithFixedDelay retourneren een ScheduledFuture. Roep cancel(false) aan om toekomstige uitvoeringen te stoppen zonder de actieve uitvoering te onderbreken:
ScheduledFuture<?> sf = scheduler.scheduleAtFixedRate(
() -> System.out.println("Heartbeat"), 0, 1, TimeUnit.SECONDS);
// Cancel after 5 seconds
scheduler.schedule(() -> sf.cancel(false), 5, TimeUnit.SECONDS);Uitzonderingen afhandelen in geplande taken
Als een geplande taak een niet-afgevangen uitzondering werpt, stopt de planner stilzwijgend met herhalen — er volgen geen uitvoeringen meer. Omwikkel de taak daarom altijd met try-catch:
scheduler.scheduleAtFixedRate(() -> {
try {
// risky work
if (Math.random() < 0.3) throw new RuntimeException("transient");
System.out.println("Success");
} catch (Exception e) {
System.err.println("Task error: " + e.getMessage());
// task continues to run on next interval
}
}, 0, 2, TimeUnit.SECONDS);Praktisch: cache vernieuwen
Gebruik een geplande taak om een cache regelmatig te vernieuwen:
class PriceCache {
private volatile Map<String, Double> prices = new HashMap<>();
PriceCache(ScheduledExecutorService scheduler) {
scheduler.scheduleAtFixedRate(this::refresh, 0, 30, TimeUnit.SECONDS);
}
private void refresh() {
System.out.println("Refreshing prices...");
// prices = fetchFromDatabase();
}
Double getPrice(String symbol) { return prices.get(symbol); }
}Praktisch: opnieuw proberen met oplopende vertraging
Implementeer opnieuw proberen met exponentiële wachttijd via geplande taken:
void retryWithBackoff(Runnable task, int maxRetries, ScheduledExecutorService s) {
AtomicInteger attempts = new AtomicInteger(0);
long[] delay = {1}; // seconds
Runnable wrapper = new Runnable() {
public void run() {
try {
task.run();
} catch (Exception e) {
int n = attempts.incrementAndGet();
if (n < maxRetries) {
delay[0] *= 2;
s.schedule(this, delay[0], TimeUnit.SECONDS);
} else System.err.println("Max retries reached");
}
}
};
s.execute(wrapper);
}Monitoring: getDelay en getQueue
Bekijk de status van de planner:
ScheduledFuture<?> sf = scheduler.schedule(() -> {}, 10, TimeUnit.SECONDS);
System.out.println("Delay remaining: " + sf.getDelay(TimeUnit.SECONDS) + "s");
// ThreadPoolExecutor provides queue inspection:
if (scheduler instanceof ScheduledThreadPoolExecutor ste) {
System.out.println("Queue size: " + ste.getQueue().size());
}Afsluiten en leegmaken
Bepaal bij het afsluiten of geplande taken nog moeten worden uitgevoerd:
ScheduledThreadPoolExecutor ste = (ScheduledThreadPoolExecutor)
Executors.newScheduledThreadPool(2);
// Cancel scheduled tasks on shutdown (default: false = they run)
ste.setExecuteExistingDelayedTasksAfterShutdownPolicy(false);
ste.setContinueExistingPeriodicTasksAfterShutdownPolicy(false);
ste.shutdown();Korte controle
Een taak die is gepland met scheduleAtFixedRate(..., 1, TimeUnit.SECONDS) duurt 3 seconden. Hoe handelt de planner dit af?
Samenvatting: ScheduledExecutorService
Belangrijkste punten:
- schedule() — eenmalige uitvoering met vertraging
- scheduleAtFixedRate() — timing zonder verschuiving (van start tot start)
- scheduleWithFixedDelay() — gegarandeerde tussenruimte (van einde tot start)
- Onverwerkte uitzonderingen stoppen terugkerende taken stilletjes — gebruik altijd try-catch
- Annuleer met ScheduledFuture.cancel(false)
Leer Java met een AI-tutor — gratis
Schrijf echte code en voer die uit in je browser, krijg direct hulp van een AI-tutor die 24/7 beschikbaar is en ga verder waar je gebleven bent op het web of in de app.
- Cursussen
- 104
- Lessen
- 374
Veelgestelde vragen
Is de les “ScheduledExecutorService voor terugkerende taken” gratis?
Ja — de volledige tekst van “ScheduledExecutorService voor terugkerende taken” kun je hier gratis op het web lezen. Als je interactief wilt oefenen met een ingebouwde code-editor en een AI-begeleider die 24/7 beschikbaar is, en de rest van de cursus Java Academy wilt ontgrendelen, kun je upgraden naar CoddyKit PRO. De cursus Java Academy bevat in totaal 4 lessen.
Wat leer ik in “ScheduledExecutorService voor terugkerende taken”?
Plan taken met vaste frequenties of vaste vertragingen voor polling en onderhoud op de achtergrond. Je oefent met Java Academy door code rechtstreeks in de browser uit te voeren. Een AI-begeleider die 24/7 beschikbaar is beantwoordt je vragen terwijl je de les doorwerkt.
Heb ik ervaring nodig om met Java Academy te beginnen?
Ervaring vooraf is niet nodig. Java Academy op CoddyKit is opgebouwd voor beginners tot gevorderden, zodat je hier of bij het begin kunt starten en in je eigen tempo kunt leren. Dit is les 4 van 4.
Hoe lang duurt de les “ScheduledExecutorService voor terugkerende taken”?
De meeste lessen van CoddyKit duren ongeveer 5–10 minuten. Elke les is kort en interactief, zodat je gestaag vooruitgaat en op het web en in de app precies verdergaat waar je was gebleven.
Kan ik code schrijven en uitvoeren in deze les over Java Academy?
Ja. Elke les over Java Academy bevat een ingebouwde code-editor, zodat je rechtstreeks in je browser echte code kunt schrijven en uitvoeren en direct feedback van AI krijgt — lokale installatie is niet nodig.
Alle lessen in deze cursus
- ExecutorService en typen threadpools
- Taken indienen: Runnable versus Callable
- Future en foutafhandeling
- ScheduledExecutorService voor terugkerende taken