1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

package main

import (

    "fmt"

    "time"

)

func main() {

    // 创建一个 Timer，设置 2 秒后触发

    timer := time.NewTimer(2 * time.Second)

    // 等待 Timer 触发

    <-timer.C

    fmt.Println("Timer expired")

    // 如果你想要停止 Timer，可以使用 Stop() 方法

    // timer.Stop()

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

package main

import (

    "fmt"

    "time"

)

func main() {

    // 使用 time.After 创建一个无缓冲的 Timer

    timerCh := time.After(2 * time.Second)

    // 等待 Timer 触发

    <-timerCh

    fmt.Println("Timer expired")

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

package main

import (

    "fmt"

    "time"

)

type MyTimer struct {

    duration time.Duration

    timer    *time.Timer

    resetCh  chan time.Duration

    stopCh   chan struct{}

}

func NewMyTimer(duration time.Duration) *MyTimer {

    t := &MyTimer{

        duration: duration,

        resetCh:  make(chan time.Duration),

        stopCh:   make(chan struct{}),

    }

    t.timer = time.NewTimer(duration)

    go t.run()

    return t

}

func (t *MyTimer) run() {

    for {

        select {

        case <-t.timer.C:

            fmt.Println("Timer expired")

            return

        case newDuration := <-t.resetCh:

            if !t.timer.Stop() {

                <-t.timer.C

            }

            t.timer.Reset(newDuration)

        case <-t.stopCh:

            if !t.timer.Stop() {

                <-t.timer.C

            }

            return

        }

    }

}

func (t *MyTimer) Reset(duration time.Duration) {

    t.resetCh <- duration

}

func (t *MyTimer) Stop() {

    t.stopCh <- struct{}{}

}

func main() {

    timer := NewMyTimer(2 * time.Second)

    time.Sleep(1 * time.Second)

    timer.Reset(3 * time.Second)

    time.Sleep(2 * time.Second)

    timer.Stop()

    fmt.Println("Timer stopped")

}