Go Academy · Leçon

Arrêt progressif des tâches

Arrêter proprement les tâches

Arrêt progressif des tâches est une leçon Go Academy gratuite sur CoddyKit. Ceci est la leçon 4 sur 4. Tu peux lire la leçon complète ci-dessous gratuitement — puis la pratiquer en direct dans le navigateur avec un éditeur de code intégré et un tuteur IA 24/7. Elle fait partie du parcours d'apprentissage Go Academy, et ta progression se synchronise sur le web et l'application CoddyKit. Le cours Go Academy comprend 4 leçons au total.

Arrêter les tâches proprement

Un planificateur interrompu au milieu d'une tâche peut corrompre des données ou laisser un travail à moitié terminé. Un arrêt progressif signifie : cesser d'accepter de nouvelles exécutions, laisser les tâches en cours se terminer (jusqu'à une échéance), puis quitter.

Écouter les signaux

Interceptez les signaux du système d'exploitation comme SIGINT (Ctrl+C) et SIGTERM (arrêt de l'orchestrateur) afin de pouvoir arrêter le programme volontairement.

sig := make(chan os.Signal, 1)
signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
<-sig
fmt.Println("shutting down")

signal.NotifyContext

Go 1.16+ propose un utilitaire pratique qui annule un contexte lorsqu'un signal arrive.

ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
defer stop()
<-ctx.Done()

Arrêter le planificateur

Avec robfig/cron, c.Stop() renvoie un contexte qui est terminé lorsque toutes les tâches en cours sont achevées. Attendez-le pour laisser les tâches se terminer.

ctx := c.Stop()        // stops scheduling, returns ctx
<-ctx.Done()            // wait for running jobs
fmt.Println("all jobs finished")

Propager l'annulation aux tâches

Transmettez un contexte à chaque tâche afin que les travaux de longue durée puissent s'interrompre rapidement lorsque l'arrêt commence.

func job(ctx context.Context) {
    select {
    case <-time.After(time.Hour):
    case <-ctx.Done():
        return // bail out early
    }
}

Limiter l'attente

N'attendez pas indéfiniment des tâches bloquées. Utilisez un contexte avec délai d'attente afin que l'arrêt se termine même si une tâche reste bloquée.

shutCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()

WaitGroups pour les planificateurs personnalisés

Si vous créez votre propre planificateur avec des gouroutines, suivez-les avec un sync.WaitGroup et appelez Wait() pendant l'arrêt.

var wg sync.WaitGroup
wg.Add(1)
go func() { defer wg.Done(); doWork() }()
// shutdown:
wg.Wait()

Éviter de démarrer de nouvelles tâches

Une fois l'arrêt commencé, le minuteur périodique ou cron doit cesser de se déclencher. Fermer un canal de fin ou annuler le contexte garantit que la boucle reçoit le signal et cesse de planifier de nouvelles exécutions.

L'idempotence est utile

Concevez les tâches pour qu'elles puissent être réexécutées sans danger. Si une tâche est interrompue en cours d'exécution puis relancée après un redémarrage, une logique idempotente évite les effets en double (envoi d'e-mails en double, prélèvements en double).

Le schéma complet

Pour tout réunir : un contexte qui se notifie à la réception d'un signal, un appel à Stop de cron qui renvoie un contexte d'attente de fin et un délai d'attente plafonné. Il s'agit de la structure de base standard pour l'arrêt progressif des services planifiés.

Exécutable : arrêt progressif avec un contexte

Ce programme autonome exécute un processus périodique et l'arrête progressivement grâce à l'annulation du contexte, en attendant la fin de l'impulsion en cours.

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func main() {
    ctx, cancel := context.WithCancel(context.Background())
    var wg sync.WaitGroup
    wg.Add(1)
    go func() {
        defer wg.Done()
        t := time.NewTicker(5 * time.Millisecond)
        defer t.Stop()
        for {
            select {
            case <-t.C:
                fmt.Println("working")
            case <-ctx.Done():
                fmt.Println("stopping cleanly")
                return
            }
        }
    }()
    time.Sleep(17 * time.Millisecond)
    cancel()   // signal shutdown
    wg.Wait()  // wait for worker to finish
    fmt.Println("shutdown complete")
}

Vérification rapide

Vérifiez votre compréhension de l'arrêt progressif des tâches.

Récapitulatif

Vous avez découvert l'arrêt progressif des tâches :

Interceptez SIGINT/SIGTERM, idéalement avec signal.NotifyContext
cron.Stop() renvoie un contexte qui attend la fin des tâches en cours
Propagez le contexte aux tâches et limitez l'attente avec un délai d'attente
Rendez les tâches idempotentes afin que les nouvelles tentatives soient sans danger

Questions Fréquemment Posées

La leçon « Arrêt progressif des tâches » est-elle gratuite ?

Oui — le texte complet de « Arrêt progressif des tâches » est gratuit à lire ici sur le web. Pour la pratiquer de manière interactive (un éditeur de code intégré et un tuteur IA 24/7) et déverrouiller le reste du cours Go Academy, passe à CoddyKit PRO. Le cours Go Academy comprend 4 leçons au total.

Qu'est-ce que j'apprendrai dans « Arrêt progressif des tâches » ?

Arrêter proprement les tâches Tu pratiques Go Academy avec du code pratique que tu exécutes directement dans le navigateur, et un tuteur IA 24/7 répond à tes questions au fur et à mesure que tu avances dans la leçon.

Dois-je avoir de l'expérience pour commencer Go Academy ?

Aucune expérience préalable n'est requise. Go Academy sur CoddyKit est structuré pour les débutants jusqu'aux apprenants avancés, donc tu peux commencer ici ou depuis le début et avancer à ton rythme. Ceci est la leçon 4 sur 4.

Combien de temps prend la leçon « Arrêt progressif des tâches » ?

La plupart des leçons CoddyKit prennent environ 5–10 minutes. Chacune est courte et interactive, tu progresses régulièrement et tu repiques exactement où tu t'es arrêté sur le web et l'app.

Peux-tu écrire et exécuter du code dans cette leçon Go Academy ?

Oui. Chaque leçon Go Academy inclut un éditeur de code intégré, tu écris et exécutes du vrai code directement dans ton navigateur et tu reçois des retours IA instantanés — aucune configuration locale requise.

Toutes les leçons de ce cours

← Retour à Go Academy