Rumah  >  Artikel  >  pembangunan bahagian belakang  >  Bagaimana untuk Menghentikan Goroutine Berjalan di Saluran Ticker dengan Anggun dalam Go?

Bagaimana untuk Menghentikan Goroutine Berjalan di Saluran Ticker dengan Anggun dalam Go?

Patricia Arquette
Patricia Arquetteasal
2024-11-09 01:40:02434semak imbas

How to Gracefully Stop a Goroutine Running on a Ticker Channel in Go?

Mengurus Ticker Stop Gelagat dalam Go

Apabila berurusan dengan saluran, adalah penting untuk mempertimbangkan gelagat operasi hantar dan terima. Dalam kes saluran ticker, memanggil ticker.Stop() akan menghentikan ticker daripada menghasilkan nilai baharu, tetapi saluran itu sendiri tetap terbuka.

Cabaran: Gantung Goroutine

Coretan kod yang disediakan menunjukkan goroutine yang berjulat pada saluran ticker. Walau bagaimanapun, apabila ticker.Stop() dipanggil, goroutine kekal aktif selama-lamanya kerana saluran tidak ditutup.

Penyelesaian: Menggunakan Saluran Kedua

Untuk mengendalikan dengan anggun keadaan ini, saluran sekunder (berhenti) boleh diperkenalkan. Goroutine boleh mendengar pada kedua-dua saluran ticker dan saluran henti dalam pernyataan pilih. Apabila isyarat untuk berhenti diterima pada saluran berhenti, goroutine boleh menutup sendiri dan keluar.

Kod yang diubah suai di bawah menggabungkan penyelesaian ini:

package main

import (
    "log"
    "time"
)

// Every runs the provided function every tick.
// Return false from the function to stop the ticker.
func Every(duration time.Duration, work func(time.Time) bool) chan bool {
    ticker := time.NewTicker(duration)
    stop := make(chan bool, 1)

    go func() {
        defer log.Println("ticker stopped")
        for {
            select {
            case time := <-ticker.C:
                if !work(time) {
                    stop <- true
                }
            case <-stop:
                return
            }
        }
    }()

    return stop
}

func main() {
    stop := Every(1*time.Second, func(time.Time) bool {
        log.Println("tick")
        return true
    })

    time.Sleep(3 * time.Second)
    log.Println("stopping ticker")
    stop <- true
    time.Sleep(3 * time.Second)
}

Apabila ticker.Stop() adalah kini dipanggil, isyarat dihantar pada saluran berhenti, menyebabkan goroutine keluar dengan anggun, walaupun selepas penanda berhenti menghasilkan nilai.

Atas ialah kandungan terperinci Bagaimana untuk Menghentikan Goroutine Berjalan di Saluran Ticker dengan Anggun dalam Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn