Décrivez comment les processus de travail ont été construits et gérés dans votre organisation précédente.

Dans l’organisation précédente, les processus de travail étaient construits en utilisant des goroutines et des canaux en Go pour gérer efficacement les tâches parallèles.

Points clés :

• Chaque tâche était lancée dans une goroutine séparée, permettant d’exécuter plusieurs processus simultanément.
• Des canaux étaient utilisés pour synchroniser et transférer des données entre les goroutines, assurant un échange d’informations sécurisé.
• Pour contrôler la fin du travail, sync.WaitGroup était utilisé pour attendre la fin de toutes les goroutines.

Exemple :

var wg sync.WaitGroup
jobs := make(chan int, 10)

worker := func(id int, jobs <-chan int, wg *sync.WaitGroup) {
    defer wg.Done()
    for job := range jobs {
        fmt.Printf("Travailleur %d traitant la tâche %d\n", id, job)
        // traitement de la tâche
    }
}

func main() {
    for w := 1; w <= 3; w++ {
        wg.Add(1)
        go worker(w, jobs, &wg)
    }

    for j := 1; j <= 5; j++ {
        jobs <- j
    }
    close(jobs)

    wg.Wait()
}

Ainsi, les processus étaient organisés comme une pool de travailleurs traitant parallèlement les tâches entrantes.