Blame view

src/components/timewheel/timewheel_test.go 399 Bytes
0cc58315   zhangqijia   添加定时器, 检查心跳
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
  package timewheel
  
  import (
  	"fmt"
  	"testing"
  	"time"
  )
  var tw *TimeWheel
  
  func Add()  {
  	fmt.Println("ADD : 123456")
  	tw.AfterFunc(6*time.Second, Add)
  }
  
  func Add1()  {
  	fmt.Println("GET : 78901112")
  	tw.AfterFunc(9*time.Second, Add1)
  }
  
  func TestTimeWheel_AfterFunc(t *testing.T) {
  
  	tw = NewTimeWheel(time.Second, 5)
  	tw.Start()
  	defer tw.Stop()
  
  
  	Add()
  	Add1()
  	time.Sleep(time.Second * 200)
  }