forked from openatx/atx-agent
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathsafetimer_test.go
52 lines (48 loc) · 883 Bytes
/
safetimer_test.go
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
// +build windows
package main
import (
"sync"
"testing"
"time"
)
func TestSafeTimer(tt *testing.T) {
deadtime := time.Now().Add(2 * time.Second)
t := NewSafeTimer(100 * time.Hour)
wg := sync.WaitGroup{}
wg.Add(8)
for i := 0; i < 8; i++ {
go func() {
for {
t.Reset(10 * time.Hour)
if time.Now().After(deadtime) {
break
}
}
wg.Done()
}()
}
wg.Wait()
}
// func TestMustPanic(tt *testing.T) {
// defer func() {
// if r := recover(); r == nil {
// tt.Errorf("The code did not panic")
// }
// }()
// deadtime := time.Now().Add(2 * time.Second)
// t := time.NewTimer(100 * time.Hour)
// wg := sync.WaitGroup{}
// wg.Add(8)
// for i := 0; i < 8; i++ {
// go func() {
// for {
// t.Reset(10 * time.Hour)
// if time.Now().After(deadtime) {
// break
// }
// }
// wg.Done()
// }()
// }
// wg.Wait()
// }