fix
This commit is contained in:
parent
bf27b47427
commit
4bf786336e
2
core.go
2
core.go
@ -37,7 +37,7 @@ func NewTimeWheel(slotCount int, interval time.Duration) *TimeWheel {
|
||||
addTaskChannel: make(chan *Task, 1000),
|
||||
removeTaskChannel: make(chan *Task, 1000),
|
||||
stopChannel: make(chan bool, 1000),
|
||||
taskRecords: easymap.NewNormal(true),
|
||||
taskRecords: easymap.NewNormal(),
|
||||
job: nil,
|
||||
isRunning: false,
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user