package main

import (
    "fmt"
    "time"
)

func main() {
    // func NewTimer(d Duration) *Timer
    timer := time.NewTimer(2 * time.Second) // 設(shè)置超時(shí)時(shí)間2秒
    // 先打印下當(dāng)前時(shí)間
    fmt.Println("當(dāng)前時(shí)間:", time.Now())

    //我們可以打印下這個(gè)只讀通道的值
        //timer.C就是我們?cè)诙x定時(shí)器的時(shí)候，存放的時(shí)間，等待對(duì)應(yīng)的時(shí)間?，F(xiàn)在這個(gè)就是根據(jù)當(dāng)前時(shí)間加2秒

    fmt.Println("通道里面的值", <-timer.C)
}

package main

import (
    "fmt"
    "time"
)

func main() {
    timer := time.NewTimer(2 * time.Second) // 設(shè)置超時(shí)時(shí)間2秒
    <-timer.C
    //經(jīng)過兩秒后只想下面代碼
    fmt.Println("after 2s Time out!")
}

package main

import (
    "fmt"
    "time"
)

func main() {
    timer := time.NewTimer(2 * time.Second) // 設(shè)置超時(shí)時(shí)間2秒
    //這里，創(chuàng)建定時(shí)器后，里面執(zhí)行了停止方法，肯定是在定時(shí)器超時(shí)前停止了，返回true
    res := timer.Stop()
    fmt.Println(res) // 輸出：true
}

package main

import (
    "fmt"
    "time"
)

func main() {
    timer := time.NewTimer(2 * time.Second)
    <-timer.C
    fmt.Println("time out1")
    //經(jīng)過兩秒后，定時(shí)器超時(shí)了
    res1 := timer.Stop()
    //此時(shí)再stop，得到的是false
    fmt.Printf("res1 is %t\n", res1) // 輸出：false
    //然后我們重置定時(shí)器。重置成3秒后超時(shí)
    timer.Reset(3 * time.Second)
    res2 := timer.Stop()
    //此時(shí)再stop，由于定時(shí)器沒超時(shí)，得到的是true
    fmt.Printf("res2 is %t\n", res2) // 輸出：true
}

package main

import (
    "fmt"
    "time"
)

func main() {
    duration := time.Duration(1) * time.Second
    f := func() {
        fmt.Println("f has been called after 1s by time.AfterFunc")
    }
    // func AfterFunc(d Duration, f func()) *Timer
    //等待duration時(shí)間后，執(zhí)行f函數(shù)
    //這里是經(jīng)過1秒后。執(zhí)行f函數(shù)
    timer := time.AfterFunc(duration, f)
    defer timer.Stop()
    time.Sleep(2 * time.Second)
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan string)
    go func() {
        time.Sleep(3 * time.Second)
        ch <- "test"
    }()
    
    //使用select，哪個(gè)先到來，耗時(shí)時(shí)間短，執(zhí)行哪個(gè)
    select {
    case val := <-ch:
        fmt.Printf("val is %s\n", val)
    // 這個(gè)case是兩秒后執(zhí)行
    // func After(d Duration) <-chan Time
    case <-time.After(2 * time.Second):
        fmt.Println("timeout!!!")
    }
}

ticker := time.NewTicker(1 * time.Second)

for range ticker.C {  
    // 在這里執(zhí)行周期性任務(wù)  
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ticker := time.NewTicker(1 * time.Second)
    //查看定時(shí)器數(shù)據(jù)類型
    fmt.Printf("定時(shí)器數(shù)據(jù)類型%T\n", ticker)
    //啟動(dòng)協(xié)程來監(jiān)聽定時(shí)器觸發(fā)事件，通過time.Sleep函數(shù)來等待5秒鐘，然后調(diào)用ticker.Stop()函數(shù)來停止定時(shí)器。
    //最后，輸出"定時(shí)器停止"表示定時(shí)器已經(jīng)成功停止。
    go func() {
        for range ticker.C {
            fmt.Println("Ticker ticked")
        }

    }()

    //執(zhí)行5秒后，讓定時(shí)器停止
    time.Sleep(5 * time.Second)
    ticker.Stop()
    fmt.Println("定時(shí)器停止")
}

select {  
case t := <-ticker.C:  
    // 處理Ticker定時(shí)器事件  
case <-stopChan:  
    // 處理停止信號(hào)  
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ticker := time.NewTicker(1 * time.Second) // 創(chuàng)建一個(gè)每秒觸發(fā)一次的Ticker定時(shí)器
    defer ticker.Stop()                       // 確保在main函數(shù)結(jié)束時(shí)停止定時(shí)器

    for {
        select {
        case t := <-ticker.C:
            fmt.Println("Tick at", t)
        }
    }
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ticker := time.NewTicker(500 * time.Millisecond) // 創(chuàng)建一個(gè)每500毫秒觸發(fā)一次的Ticker定時(shí)器
    timeEnd := make(chan bool)                       // 用于停止Ticker定時(shí)器的通道

    go func() {
        for {
            select {
            //當(dāng)達(dá)到設(shè)置的停止條件式，停止循環(huán)
            case <-timeEnd:
                fmt.Println("===結(jié)束任務(wù)")
                break
            case t := <-ticker.C:
                fmt.Println("==500毫秒響應(yīng)一次:", t)
            }
        }
    }()

    time.Sleep(5 * time.Second) // 主線程等待5秒鐘
    ticker.Stop()               // 停止Ticker定時(shí)器
    timeEnd <- true             // 發(fā)送結(jié)束信號(hào)

    fmt.Println("===定時(shí)任務(wù)結(jié)束===")
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ticker := time.NewTicker(5 * time.Second)
    defer ticker.Stop() // 確保程序結(jié)束時(shí)停止Ticker定時(shí)器

    for range ticker.C {
        // 打印當(dāng)前時(shí)間作為日志
        fmt.Println("Current time:", time.Now())
    }
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ticker := time.NewTicker(5 * time.Second)
    stopChan := make(chan struct{})

    go func() {
        // 模擬一個(gè)運(yùn)行一段時(shí)間的任務(wù)
        time.Sleep(15 * time.Second)
        // 發(fā)送停止信號(hào)
        stopChan <- struct{}{}
    }()

    for {
        select {
        case t := <-ticker.C:
            fmt.Println("Tick at", t)
        case <-stopChan:
            fmt.Println("Ticker stopped")
            ticker.Stop()
            return
        }
    }
}

package main

import (
    "fmt"
    "math/rand"
    "time"
)

// 模擬檢查系統(tǒng)狀態(tài)的函數(shù)
func checkSystemStatus() {
    // 這里可以添加實(shí)際的檢查邏輯
    // 例如：檢查CPU使用率、內(nèi)存使用情況等
    // 這里我們隨機(jī)生成一個(gè)0到100之間的數(shù)作為模擬結(jié)果
    status := rand.Intn(101)
    fmt.Printf("System status: %d\n", status)

    // 假設(shè)狀態(tài)大于80表示系統(tǒng)異常
    if status > 80 {
        fmt.Println("Warning: System status is above normal!")
        // 這里可以添加處理異常的邏輯
        // 例如：發(fā)送警報(bào)、重啟服務(wù)等
    }
}

func main() {
    ticker := time.NewTicker(10 * time.Second)
    defer ticker.Stop() // 確保程序結(jié)束時(shí)停止Ticker定時(shí)器

    for range ticker.C {
        checkSystemStatus()
    }
}