Apakah cara yang betul untuk mencapai penutupan anggun proses latar belakang dalam Uber FX?

Apakah cara yang betul untuk mencapai penutupan anggun proses latar belakang dalam Uber FX? Ini adalah masalah biasa yang dihadapi ramai orang apabila menggunakan Uber FX. Sebagai rangka kerja pemprosesan tugas latar belakang yang berkuasa, Uber FX menyediakan cara yang mudah dan berkesan untuk mengurus dan memproses tugasan latar belakang. Dalam artikel ini, editor PHP Zimo akan memperkenalkan anda cara menutup proses latar belakang dengan betul untuk memastikan kestabilan dan operasi normal program.

Kandungan soalan

Andaikan saya mempunyai perkhidmatan dalam aplikasi Uber FX saya yang sepatutnya melakukan beberapa aktiviti latar belakang, seperti mengundi API luaran. Saya boleh menjalankan tugas latar belakang dengan mencetuskan goroutine, tetapi apakah cara yang betul untuk menghentikannya?

Sebagai pelaksanaan yang mungkin, mari kita pertimbangkan contoh berikut:

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()
}

Beberapa nota:

• Perkhidmatan disambungkan kepada kitaran hayat aplikasi dengan menggunakan fx.Lifecycle cangkuk.
• Saya tidak boleh bergantung pada dan menggunakan konteks dalam kaedah OnStart/OnStop kerana ia adalah konteks yang berbeza dan sepadan dengan memulakan/berhenti aktiviti, bukan konteks kitaran hayat apl.

Kebimbangan dan Soalan:

• Contoh yang diberikan agak berat untuk mengesan tugas latar belakang. Selain itu, menyimpan konteks dalam struct ialah anti-corak. Adakah terdapat cara untuk memudahkan ini?
• Perlukah saya menunggu goroutine selesai jika tiada sumber untuk dikeluarkan?

Penyelesaian

Pada pendapat saya, menggunakan konteks adalah baik, tetapi anda juga boleh menyampaikan isyarat penutupan melalui saluran ke mana-mana rutin Go yang anda mahukan. Lihat kod contoh di bawah.

Ya, anda juga harus menunggu kiraan kumpulan tunggu kembali kepada sifar sebelum menutup apl sepenuhnya. Jadi anda tutup saluran dahulu dan kemudian tunggu kumpulan menunggu.

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()
}

Atas ialah kandungan terperinci Apakah cara yang betul untuk mencapai penutupan anggun proses latar belakang dalam Uber FX?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!