第一版时间轮任务调度实现 #1
8
core.go
8
core.go
@ -21,6 +21,14 @@ import (
|
|||||||
//
|
//
|
||||||
// Date : 16:50 2023/8/11
|
// Date : 16:50 2023/8/11
|
||||||
func NewTimeWheel(slotCount int, interval time.Duration) *TimeWheel {
|
func NewTimeWheel(slotCount int, interval time.Duration) *TimeWheel {
|
||||||
|
if slotCount <= 0 {
|
||||||
|
// 默认100个槽位
|
||||||
|
slotCount = 100
|
||||||
|
}
|
||||||
|
if interval.Seconds() == 0 {
|
||||||
|
// 默认60s扫描一次
|
||||||
|
interval = time.Second * 60
|
||||||
|
}
|
||||||
tw := &TimeWheel{
|
tw := &TimeWheel{
|
||||||
Interval: interval,
|
Interval: interval,
|
||||||
Slots: make([]*list.List, slotCount),
|
Slots: make([]*list.List, slotCount),
|
||||||
|
Loading…
Reference in New Issue
Block a user