Golang의 간격으로 반복적 인 작업을 수행 할 수있는 방법이 있습니까?

Question

이동에서 반복되는 백그라운드 작업을 수행 할 수있는 방법이 있습니까? Java에서 Timer.schedule(task, delay, period)과 같은 것을 생각하고 있습니다. 나는 goroutine과 Time.sleep()으로 이것을 할 수 있다는 것을 알고 있지만, 나는 쉽게 멈추는 것을 원합니다.

다음은 내가 가지고 있지만,보기 흉한 것 같습니다. 클리너/더 좋은 방법이 있습니까?

package main 

import (
    "fmt" 
    "time" 
) 

func schedule(what func(), delay time.Duration) chan bool { 
    stop := make(chan bool) 

    go func() { 
     for { 
      what() 
      select { 
      case <-time.After(delay): 
      case <-stop: 
       return 
      } 
     } 
    }() 

    return stop 
} 

func main() { 
    ping := func() { fmt.Println("#") } 

    stop := schedule(ping, 5*time.Millisecond) 
    time.Sleep(25 * time.Millisecond) 
    stop <- true 
    time.Sleep(25 * time.Millisecond) 

    fmt.Println("Done") 
} 

Playground

Answer 1

기능 time.NewTicker 같은 대한주기적인 메시지를 전송하는 채널을 만들고, 그것을 막을 수있는 방법을 제공하는 방법

func oneWay() { 
    var f func() 
    var t *time.Timer 

    f = func() { 
     fmt.Println("doing stuff") 
     t = time.AfterFunc(time.Duration(5) * time.Second, f) 
    } 

    t = time.AfterFunc(time.Duration(5) * time.Second, f) 

    defer t.Stop() 

    //simulate doing stuff 
    time.Sleep(time.Minute) 
} 

Answer 2

.

ticker := time.NewTicker(5 * time.Second) 
quit := make(chan struct{}) 
go func() { 
    for { 
     select { 
     case <- ticker.C: 
      // do stuff 
     case <- quit: 
      ticker.Stop() 
      return 
     } 
    } 
}() 

당신은 quit 채널을 닫아 노동자를 중지 할 수 있습니다 : close(quit) 그것은이 (테스트되지 않은) 같은 것을 사용합니다.

Answer 3

이 질문에 대한 광범위한 대답은 종종 Occam에서 사용되며 JCSP을 통해 Java 커뮤니티에 제공되는 레거 벽돌 접근 방식을 고려할 수 있습니다. 이 아이디어에는 매우 좋은 presentation by Peter Welch가 있습니다.

Go는 Occam과 동일한 통신 순차 프로세스 기본을 사용하기 때문에이 플러그 앤 플레이 방식은 직접 Go로 변환됩니다.

반복적 인 작업을 설계 할 때 시스템을 채널을 통해 이벤트 (메시지 또는 신호)를 교환하는 간단한 구성 요소 (goroutines)로 구성된 데이터 흐름 네트워크로 구축 할 수 있습니다.

이 접근법은 구성 적입니다. 작은 구성 요소의 각 그룹은 그 자체로 더 큰 구성 요소, 즉 무한대로 작동 할 수 있습니다. 복잡한 동시 시스템이 이해하기 쉬운 벽돌로 만들어지기 때문에 이것은 매우 강력 할 수 있습니다.

각주 : Welch의 프레젠테이션에서 채널에 대한 Occam 구문을 사용합니다 ()! 및 ?이고 이것들은 Go에 직접 ch <- 및 < -ch에 직접 해당합니다.

Answer 4

체크 아웃이 라이브러리 : 아래 https://github.com/robfig/cron

예 :

c := cron.New() 
c.AddFunc("0 30 * * * *", func() { fmt.Println("Every hour on the half hour") }) 
c.AddFunc("@hourly",  func() { fmt.Println("Every hour") }) 
c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty") }) 
c.Start() 

Answer 5

당신이 틱은 (는 각 실행에 이전했다 한 시간에 따라) 변화에 대해 상관하지 않으면 당신은 할 채널을 사용하지 않으려면 기본 범위 기능을 사용할 수 있습니다.

즉

package main 

import "fmt" 
import "time" 

func main() { 
    go heartBeat() 
    time.Sleep(time.Second * 5) 
} 
func heartBeat(){ 
    for range time.Tick(time.Second *1){ 
     fmt.Println("Foo") 
    } 
} 

Playground