README
¶
timer
Go implementation of Kafka's Hierarchical Timing Wheels.
timerGo implementation of Kafka's Hierarchical Timing Wheels.timedglobaltimerinstance, that tick is 1ms. wheel size is 1024, use ants goroutine pool.
Usage
Installation
Use go get.
go get github.com/thinkgos/timer
Then import the package into your own code.
import "github.com/thinkgos/timer"
Example
package main
import (
"fmt"
"sync"
"time"
"github.com/thinkgos/timer/timed"
)
func main() {
var wg sync.WaitGroup
for i := 0; i < 1000; i++ {
wg.Add(1)
index := i
_, _ = timed.AfterFunc(time.Duration(i)*100*time.Millisecond, func() {
fmt.Printf("%s: timer task %d is executed, remain task: %d\n", time.Now().String(), index, timed.TaskCounter())
wg.Done()
})
}
wg.Wait()
}
References
License
This project is under MIT License. See the LICENSE file for the full license text.
Documentation
¶
Index ¶
Examples ¶
Constants ¶
View Source
const ( DefaultTickMs int64 = 1 DefaultWheelSize = 1024 )
Variables ¶
View Source
var (
ErrClosed = errors.New("timer: use of closed timer")
)
Functions ¶
func NextPowOf2 ¶
Types ¶
type Spoke ¶
type Spoke struct {
// contains filtered or unexported fields
}
func (*Spoke) GetExpiration ¶
Get the spoke's expiration time
func (*Spoke) SetExpiration ¶
Set the spoke's expiration time Returns true if the expiration time is changed
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
Task 是双向链表的一个元素.
func NewTaskFunc ¶
NewTaskFunc new task with delay duration and function job, the accuracy is milliseconds.
func (*Task) ExpirationMs ¶
ExpirationMs expiration milliseconds.
type Timer ¶
type Timer struct {
// contains filtered or unexported fields
}
Example ¶
tm := NewTimer()
tm.Start()
_, _ = tm.AfterFunc(100*time.Millisecond, func() {
fmt.Println(100)
})
_ = tm.AddTask(NewTask(1025 * time.Millisecond).WithJobFunc(func() {
fmt.Println(200)
}))
canceledTaskAfterAdd := NewTask(300 * time.Millisecond).WithJobFunc(func() {
fmt.Println("canceled after add")
})
_ = tm.AddTask(canceledTaskAfterAdd)
canceledTaskAfterAdd.Cancel()
canceledTaskBeforeAdd := NewTask(301 * time.Millisecond).WithJobFunc(func() {
fmt.Println("canceled before add")
})
canceledTaskBeforeAdd.Cancel()
_ = tm.AddTask(canceledTaskBeforeAdd)
time.Sleep(time.Second + time.Millisecond*200)
tm.Stop()
Output: 100 200
func (*Timer) TaskCounter ¶
TaskCounter task total number of tasks.
type TimingWheel ¶
type TimingWheel struct {
// contains filtered or unexported fields
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.