Inhaltsverzeichnis
Frageninhalt
Workaround
Heim Backend-Entwicklung Golang Was ist der richtige Weg, um Hintergrundprozesse in Uber FX ordnungsgemäß herunterzufahren?

Was ist der richtige Weg, um Hintergrundprozesse in Uber FX ordnungsgemäß herunterzufahren?

Feb 08, 2024 pm 11:27 PM

在 Uber FX 中实现后台进程正常关闭的正确方法是什么?

Was ist der richtige Weg, um Hintergrundprozesse in Uber FX ordnungsgemäß herunterzufahren? Dies ist ein häufiges Problem, auf das viele Menschen bei der Nutzung von Uber FX stoßen. Als leistungsstarkes Framework für die Verarbeitung von Hintergrundaufgaben bietet Uber FX eine einfache und effektive Möglichkeit, Hintergrundaufgaben zu verwalten und zu verarbeiten. In diesem Artikel stellt Ihnen der PHP-Editor Zimo vor, wie Sie den Hintergrundprozess korrekt schließen, um die Stabilität und den normalen Betrieb des Programms sicherzustellen.

Frageninhalt

Angenommen, ich habe einen Dienst in meiner Uber FX-Anwendung, der einige Hintergrundaktivitäten ausführen soll, beispielsweise das Abfragen einer externen API. Ich kann Hintergrundaufgaben ausführen, indem ich eine Goroutine auslöse, aber wie kann ich sie richtig stoppen?

Als mögliche Umsetzung betrachten wir folgendes Beispiel:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

package main

 

import (

    "context"

    "log"

    "sync"

    "time"

 

    "go.uber.org/fx"

)

 

type AwesomeService struct {

    // context to use for background processes

    bg context.Context

    // to trigger background processes stopping

    cancel context.CancelFunc

    // to wait for background processes to gracefully finish

    wg *sync.WaitGroup

}

 

func New(lc fx.Lifecycle) *AwesomeService {

    bg, cancel := context.WithCancel(context.Background())

    service := &AwesomeService{

        bg:     bg,

        cancel: cancel,

        wg:     new(sync.WaitGroup),

    }

 

    lc.Append(fx.Hook{

        OnStart: service.start,

        OnStop:  service.stop,

    })

    return service

}

 

func (s *AwesomeService) start(_ context.Context) error {

    s.runBackgroundProcess()

    log.Println("Start done")

    return nil

}

 

func (s *AwesomeService) stop(_ context.Context) error {

    s.cancel()

    s.wg.Wait()

    log.Println("Stop done")

    return nil

}

 

// runBackgroundProcess does some work till context is done.

func (s *AwesomeService) runBackgroundProcess() {

    s.wg.Add(1)

    go func() {

        defer s.wg.Done()

        for {

            select {

            case <-s.bg.Done():

                return

            case <-time.After(1 * time.Second):

                log.Println("Working...")

            }

        }

    }()

}

 

func main() {

    fx.New(

        fx.Provide(New),

        fx.Invoke(func(*AwesomeService) {}),

    ).Run()

}

Nach dem Login kopieren

Einige Anmerkungen:

  • Der Dienst ist über fx.Lifecycle Hooks mit dem Anwendungslebenszyklus verbunden.
  • Ich kann mich in der OnStart/OnStop-Methode nicht auf den Kontext verlassen und ihn verwenden, da es sich um unterschiedliche Kontexte handelt und dem Starten/Stoppen von Aktivitäten entspricht, nicht dem Kontext des App-Lebenszyklus.

Bedenken und Fragen:

  • Das angegebene Beispiel beschäftigt sich ziemlich intensiv mit der Verfolgung von Hintergrundaufgaben. Darüber hinaus ist das Speichern von Kontext in einer Struktur ein Anti-Pattern. Gibt es eine Möglichkeit, dies zu vereinfachen?
  • Soll ich warten, bis die Goroutine fertig ist, wenn keine Ressourcen zum Freigeben vorhanden sind?

Workaround

Meiner Meinung nach ist die Verwendung eines Kontexts in Ordnung, aber Sie können auch ein Shutdown-Signal über einen Kanal an jede gewünschte Go-Routine übermitteln. Siehe Beispielcode unten.

Ja, Sie sollten auch warten, bis die Anzahl der Wartegruppen auf Null zurückgegangen ist, bevor Sie die App vollständig schließen. Sie schließen also zunächst den Kanal und warten dann auf die Wartegruppe.

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

package main

 

import (

    "context"

    "log"

    "sync"

    "time"

 

    "go.uber.org/fx"

)

 

type AwesomeService struct {

    // channel to shutdown background processes

    shutdown chan struct{}

    // to wait for background processes to gracefully finish

    wg *sync.WaitGroup

}

 

func New(lc fx.Lifecycle) *AwesomeService {

    service := &AwesomeService{

        shutdown: make(chan struct{}),

        wg:     new(sync.WaitGroup),

    }

 

    lc.Append(fx.Hook{

        OnStart: service.start,

        OnStop:  service.stop,

    })

    return service

}

 

func (s *AwesomeService) start(_ context.Context) error {

    s.runBackgroundProcess()

    log.Println("Start done")

    return nil

}

 

func (s *AwesomeService) stop(_ context.Context) error {

    close(s.shutdown)

    s.wg.Wait()

    log.Println("Stop done")

    return nil

}

 

// runBackgroundProcess does some work till context is done.

func (s *AwesomeService) runBackgroundProcess() {

    s.wg.Add(1)

    go func() {

        defer s.wg.Done()

        for {

            select {

            case <-s.shutdown:

                return

            case <-time.After(1 * time.Second):

                log.Println("Working...")

            }

        }

    }()

}

 

func main() {

    fx.New(

        fx.Provide(New),

        fx.Invoke(func(*AwesomeService) {}),

    ).Run()

}

Nach dem Login kopieren

Das obige ist der detaillierte Inhalt vonWas ist der richtige Weg, um Hintergrundprozesse in Uber FX ordnungsgemäß herunterzufahren?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
2 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Repo: Wie man Teamkollegen wiederbelebt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Abenteuer: Wie man riesige Samen bekommt
3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
2 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Repo: Wie man Teamkollegen wiederbelebt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Abenteuer: Wie man riesige Samen bekommt
3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heiße Artikel -Tags

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich? GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich? Mar 03, 2025 pm 05:17 PM

GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich?

Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren? Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren? Mar 03, 2025 pm 05:22 PM

Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren?

Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache? Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache? Mar 03, 2025 pm 05:18 PM

Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache?

Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go? Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go? Mar 10, 2025 pm 05:38 PM

Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go?

Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren? Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren? Mar 10, 2025 pm 03:20 PM

Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren?

Wie schreibt man Unit -Tests in Go? Wie schreibt man Unit -Tests in Go? Mar 21, 2025 pm 06:34 PM

Wie schreibt man Unit -Tests in Go?

Wie schreibe ich Dateien in Go Language bequem? Wie schreibe ich Dateien in Go Language bequem? Mar 03, 2025 pm 05:15 PM

Wie schreibe ich Dateien in Go Language bequem?

Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen? Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen? Mar 10, 2025 pm 05:36 PM

Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen?

See all articles