Обновленное значение не возвращается после обновления в подпрограмме go - PullRequest
0 голосов
/ 30 сентября 2018

Я столкнулся с проблемой, когда возвращаемое целое значение совпадает с заданным, даже после обновления значения в подпрограмме go.Я не могу понять, что не так.

//HostUptimeReporter - struct
type HostUptimeReporter struct {
    updateInterval int
    uptime int
    shutdownSignal chan bool

}

//NewHostUpTimeReporter - create reporter instance
func NewHostUpTimeReporter(updateIntervalInSeconds int) HostUptimeReporter {
    instance := HostUptimeReporter{updateInterval: updateIntervalInSeconds, shutdownSignal: make(chan bool), uptime:59}
    ticker := time.NewTicker(time.Duration(updateIntervalInSeconds) * time.Second)
    go func() {
        for {
            select {
            case <-ticker.C:
                instance.uptime += updateIntervalInSeconds          
                fmt.Printf("updated uptime:%v\n", instance.uptime)
            case <-instance.shutdownSignal:
                ticker.Stop()
                return
            }
        }
    }()

    return instance
}

//Shutdown - shuts down the go routine
func (hupr *HostUptimeReporter) Shutdown(){
    hupr.shutdownSignal <- true
}

func main() {

    hurp := NewHostUpTimeReporter(2)
    defer hurp.Shutdown()
    fmt.Printf("current uptime:%v\n", hurp.uptime)
    time.Sleep(3*time.Second)
    fmt.Printf("new uptime:%v\n", hurp.uptime)

}

https://play.golang.org/p/ODjSBb0YugK

Любые указатели приветствуются.

Спасибо!

1 Ответ

0 голосов
/ 30 сентября 2018

Функция, которая запускает процедуру, возвращает HostUptimeReporter:

func NewHostUpTimeReporter(updateIntervalInSeconds int) HostUptimeReporter {

Возвращая целую структуру, подобную этой, возвращает копию структуры, так что программа и вызывающая сторона NewHostUpTimeReporter смотрят на разные вещи,Вы хотите вернуть указатель, чтобы они обменивались данными:

// -----------------------------------------------------v
func NewHostUpTimeReporter(updateIntervalInSeconds int) *HostUptimeReporter {
    instance := &HostUptimeReporter{updateInterval: updateIntervalInSeconds, shutdownSignal: make(chan bool), uptime:59}
    // ---------^
    ...
...