timing wheel data race

[wllenyj]

go/time2/wheel.go

Line 148 in 2b7082d

w.tv1[index] = vec[0:0:defaultTimerSize]

go/time2/wheel.go

Line 154 in 2b7082d

for _, t := range vec {

go/time2/wheel.go

Line 112 in 2b7082d

tv[i] = append(tv[i], t)

[siddontang]

Thank you @wllenyj

Do you think what is the best way to fix it? Maybe Lock?

[wllenyj]

w.tv1[index] = make([]*timer, 0, defaultTimerSize)

or

var pool = &sync.Pool{
    New: func() interface{} {
        return make([]*timer, 0, defaultTimerSize)
    },
} 

w.tv1[index] = pool.Get().([]*timer)

f := func(vec []*timer) {
    //.....
    vec = vec[0:0:  defaultTimerSize]
    pool.Put(vec)
}

[wllenyj]

another one, should add sync/atomic

go/time2/wheel.go

Line 145 in 2b7082d

w.jiffies++

go/time2/wheel.go

Line 194 in 2b7082d

t.expires = w.jiffies + uint64(when/w.tick)

go/time2/wheel.go

Line 204 in 2b7082d

t.expires = w.jiffies + uint64(when/w.tick)