Maison  >  Article  >  développement back-end  >  Découvrez comment fermer correctement les tâches Cron dans les applications Golang

Découvrez comment fermer correctement les tâches Cron dans les applications Golang

PHPz
PHPzoriginal
2023-04-25 10:30:19990parcourir

L'utilisation de Cron Job dans les applications Golang est un moyen très populaire d'effectuer des tâches régulièrement. Ces tâches peuvent être de simples opérations répétées ou des tâches planifiées qui doivent être exécutées régulièrement. Cependant, nous devons parfois fermer une tâche Cron déjà en cours d'exécution dans l'application. Cet article explique comment fermer correctement les tâches Cron dans les applications Golang.

Qu'est-ce que Cron Job ?

Sur les ordinateurs, Cron est un programme de tâches planifiées utilisé pour exécuter des commandes et des scripts à une heure et une date spécifiques. De tels programmes peuvent être facilement trouvés sur les systèmes Unix et Linux, mais ils ont également de nombreuses autres utilisations. Dans Golang, nous pouvons utiliser des bibliothèques externes pour implémenter la fonctionnalité Cron Job.

Dans Golang, il existe plusieurs bibliothèques populaires qui peuvent être utilisées pour implémenter la fonctionnalité Cron Job. Parmi eux, les plus populaires sont Goroutines et Scheduler. Ces bibliothèques ont des fonctions spéciales, telles que les paramètres de fuseau horaire, la planification des tâches, etc. Cependant, lors de l'utilisation de ces bibliothèques, nous devons prêter attention à certains détails pour garantir que nous pouvons fermer correctement une tâche Cron déjà en cours d'exécution.

Comment fermer une tâche Cron ?

Avant de commencer à discuter de la façon de fermer Cron Job, nous devons d'abord clarifier comment implémenter Cron Job à l'aide de bibliothèques externes dans Golang. Dans cet article, nous utiliserons la bibliothèque « robfig/cron » sur GitHub.

Cette bibliothèque fournit une classe Cron qui dispose de quelques méthodes pour démarrer et arrêter la planification des tâches. Tout d’abord, nous devons importer la bibliothèque dans notre code, puis créer un objet planificateur Cron.

Dans cet exemple, nous utiliserons la bibliothèque Cron pour exécuter une tâche planifiée simple et afficher l'heure actuelle. Le code est le suivant :

import (
    "fmt"
    "time"

    "github.com/robfig/cron"
)

func main() {
    c := cron.New()
    c.AddFunc("*/1 * * * * *", func() {
        fmt.Println("Current time:", time.Now().Format("2006-01-02 15:04:05"))
    })
    c.Start()
    defer c.Stop()
    select {}
}

Dans cet exemple, nous utilisons la méthode AddFunc() pour ajouter une tâche qui s'exécute une fois par seconde. Ensuite, nous utilisons la méthode Start() pour démarrer le planificateur Cron. Enfin, à la fin de la fonction, nous arrêtons le planificateur Cron à l'aide du mot-clé defer.

Cette méthode garantit que nous arrêtons toutes les tâches avant la fermeture du programme. Cependant, cette approche présente encore quelques inconvénients, car nous ne parvenons toujours pas à arrêter l’exécution des tâches.

Pour résoudre ce problème, nous devons utiliser une autre méthode pour contrôler et arrêter Cron Job.

Comment fermer correctement la tâche Cron ?

Afin de fermer correctement le travail Cron, nous devons utiliser l'interface Schedule fournie par la bibliothèque Cron. Cette interface fournit quelques méthodes qui peuvent nous aider à contrôler et arrêter les tâches.

Dans l'exemple suivant, nous utiliserons l'interface Schedule pour implémenter une tâche planifiée qui s'exécutera dans un certain laps de temps. Nous montrerons ensuite comment fermer cette tâche planifiée à l'aide de la bibliothèque Cron.

import (
    "fmt"
    "time"

    "github.com/robfig/cron"
)

type RunnerJob struct {
    id string
}

func (j RunnerJob) Run() {
    fmt.Println("Current time:", time.Now().Format("2006-01-02 15:04:05"), "- JobID:", j.id)
}

func main() {
    c := cron.New()
    
    jobID := "jobID-001"
    job := RunnerJob{id: jobID}
    
    entryID, _ := c.Schedule(cron.Every(time.Second), job)

    fmt.Println("Entry with ID:", entryID)

    time.Sleep(10 * time.Second)
    
    c.Remove(entryID)

    defer c.Stop()
    select {}
}

Dans cet exemple, nous définissons un type RunnerJob qui implémente l'interface Job de la bibliothèque Cron. Nous utilisons ensuite la méthode Schedule() pour démarrer la tâche et enregistrer l'entryID renvoyé.

Ensuite, nous utilisons la méthode time.Sleep() pour simuler la tâche planifiée s'exécutant pendant 10 secondes. Ensuite, utilisez la méthode Remove() de la bibliothèque Cron pour arrêter la tâche planifiée.

Enfin, avant la fin de la fonction, nous devons encore appeler la méthode defer c.Stop() pour nous assurer que toutes les tâches ont été arrêtées.

Résumé

Dans cet article, nous avons expliqué comment fermer correctement une tâche Cron en cours d'exécution dans l'application Golang. Nous avons montré comment utiliser l'interface Schedule fournie par la bibliothèque Cron pour contrôler et arrêter les tâches planifiées. En suivant ces bonnes pratiques, nous pouvons implémenter correctement Cron Job dans les applications Golang.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn