[Go] 일정 시간마다 스케줄러 동작하기(Ticker)

.

 

time.Ticker 또는 time.AfterFunc, time.Sleep 등을 이용해 주기적으로 동작하는 스케줄러를 구현할 수 있습니다.
아래에서는 실무에서 자주 쓰이는 n초 간격으로 반복 실행되는 작업 프로세스를 단계적으로 정리해보겠습니다.

기본적인 time.Ticker 사용 예시

package main

import (
    "fmt"
    "time"
)

func main() {
    ticker := time.NewTicker(5 * time.Second) // 5초마다 반복
    defer ticker.Stop()

    for {
        select {
        case t := <-ticker.C:
            fmt.Println("작업 실행 시각:", t.Format("15:04:05"))
            runTask()
        }
    }
}

func runTask() {
    // 실제 비즈니스 로직
    fmt.Println("실행 중... (API 호출, DB 업데이트 등)")
}

핵심 포인트

• time.NewTicker(d)는 일정 주기로 채널에 이벤트를 보냅니다.
• for + select 구문으로 주기적 신호를 기다리며 실행합니다.
• defer ticker.Stop()으로 종료 시 리소스 해제.

 

백그라운드 고루틴에서 실행 (서버 내부용)

package main

import (
    "fmt"
    "time"
)

func startScheduler(interval time.Duration, stopChan <-chan struct{}) {
    ticker := time.NewTicker(interval)
    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            go func() {
                fmt.Println("백그라운드 작업 시작:", time.Now())
                runTask()
            }()
        case <-stopChan:
            fmt.Println("스케줄러 종료 요청")
            return
        }
    }
}

func runTask() {
    fmt.Println("작업 수행 중...")
    time.Sleep(2 * time.Second)
    fmt.Println("작업 완료.")
}

func main() {
    stopChan := make(chan struct{})
    go startScheduler(10*time.Second, stopChan)

    // 서버가 돌아가는 동안 계속 실행됨
    time.Sleep(35 * time.Second)
    close(stopChan)
}

특징

• 스케줄 작업이 고루틴으로 비동기 실행되어, 다음 주기와 겹치지 않습니다.
• stopChan을 통해 graceful stop이 가능합니다.

 

3단계: 고급형 (지연, 오류 복구 포함)

실무에서는 작업이 실패했을 때 재시도 로직을 넣거나, 작업이 오래 걸리면 다음 주기를 지연시키는 구조가 필요합니다.

func startSafeScheduler(interval time.Duration, stopChan <-chan struct{}) {
    ticker := time.NewTicker(interval)
    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            func() {
                defer func() {
                    if r := recover(); r != nil {
                        fmt.Println("작업 중 panic 발생:", r)
                    }
                }()
                if err := runTask(); err != nil {
                    fmt.Println("에러:", err)
                }
            }()
        case <-stopChan:
            fmt.Println("스케줄러 종료")
            return
        }
    }
}

func runTask() error {
    fmt.Println("DB 업데이트 또는 API 호출 중...")
    // 여기에 실제 로직
    return nil
}

이 방식은:

• panic 발생 시 복구 가능
• 다음 주기와 겹치지 않음
• 실패한 작업 로그 남김

 

대체 방식 – Cron 스타일 (github.com/robfig/cron/v3)

더 복잡한 스케줄이 필요할 때는 cron 패키지를 사용하는 것이 좋습니다.

import (
    "github.com/robfig/cron/v3"
)

func main() {
    c := cron.New()
    c.AddFunc("@every 10s", func() { runTask() })
    c.Start()

    select {} // 프로그램 유지
}

 

@every 10s, 0 0 * * * 등 다양한 스케줄 표현 가능합니다.