Merge pull request #18 from lyondhill/master

fix: add locking around timers to avoid race

clock.go

@@ -255,8 +255,13 @@ func (t *Timer) Stop() bool {
 		return t.timer.Stop()
 	}
 
+	t.mock.mu.Lock()
 	registered := !t.stopped
+	t.mock.mu.Unlock()
+
 	t.mock.removeClockTimer((*internalTimer)(t))
+	t.mock.mu.Lock()
+	defer t.mock.mu.Unlock()
 	t.stopped = true
 	return registered
 }
@@ -268,12 +273,14 @@ func (t *Timer) Reset(d time.Duration) bool {
 	}
 
 	t.next = t.mock.now.Add(d)
+	t.mock.mu.Lock()
+	defer t.mock.mu.Unlock()
+
 	registered := !t.stopped
 	if t.stopped {
-		t.mock.mu.Lock()
 		t.mock.timers = append(t.mock.timers, (*internalTimer)(t))
-		t.mock.mu.Unlock()
 	}
+
 	t.stopped = false
 	return registered
 }
@@ -288,6 +295,9 @@ func (t *internalTimer) Tick(now time.Time) {
 		t.c <- now
 	}
 	t.mock.removeClockTimer((*internalTimer)(t))
+	t.mock.mu.Lock()
+	defer t.mock.mu.Unlock()
+
 	t.stopped = true
 	gosched()
 }