timewheel

KO | EN

gitlite — search

#hacktoberfest #ai #typescript #android #rust #deep-learning #nodejs #windows #awesome-list #pytorch #ios #mcp #openai #open-source

(★ 12)

时间轮golang实现

timewheel 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# timewheel

Pure golang implementation for timewheel.

[![Go Report Card](https://goreportcard.com/badge/github.com/jhunters/timewheel?style=flat-square)](https://goreportcard.com/report/github.com/jhunters/timewheel)
[![Go](https://github.com/jhunters/timewheel/actions/workflows/go.yml/badge.svg)](https://github.com/jhunters/timewheel/actions/workflows/go.yml)
[![codecov](https://codecov.io/gh/jhunters/timewheel/branch/main/graph/badge.svg?token=dhBirUo4qL)](https://codecov.io/gh/jhunters/timewheel)
[![Releases](https://img.shields.io/github/release/jhunters/timewheel/all.svg?style=flat-square)](https://github.com/jhunters/timewheel/releases)
[![Godoc](http://img.shields.io/badge/go-documentation-blue.svg?style=flat-square)](https://godoc.org/github.com/jhunters/timewheel)
[![Go Reference](https://golang.com.cn/badge/github.com/jhunters/timewheel.svg)](https://golang.com.cn/github.com/jhunters/timewheel)
[![LICENSE](https://img.shields.io/github/license/jhunters/timewheel.svg?style=flat-square)](https://github.com/jhunters/timewheel/blob/master/LICENSE)

![pic/timewheel.png](https://raw.githubusercontent.com/jhunters/timewheel/main/pic/timewheel.png)

## Usage
### Installing

To start using timewheel, install Go and run `go get`:

```sh
$ go get github.com/jhunters/timewheel
```

### base method

create timewheel

```go
// 初始化时间轮
// 第一个参数为tick刻度, 即时间轮多久转动一次
// 第二个参数为时间轮槽slot数量
tw, err := timewheel.New(100*time.Millisecond, 300)
if err != nil {
    panic(err)
}

tw.Start()

```

add delay task

```go
// create a task bind with key, data and  time out call back function.
t := &timewheel.Task{
    Data: map[string]int{"uid": 105626, "age": 100}, // business data
    TimeoutCallback: func(task timewheel.Task) { // call back function on time out
        // process someting after time out happened. 
        fmt.Println("time out:", task.Delay(), task.Key, task.Data, task.Elasped())
    }}

// add task and return unique task id
taskid, err := tw.AddTask(5*time.Second, *t) // add delay task

```

remove delay task

```go
tw.Remove(taskid)
```

check task

```go
tw.HasTask(taskid)
```

close time wheel

```go
tw.Stop()
```
## example

[example/demo.go](example/demo.go)

timewheel

timewheel 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

timewheel

timewheel 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README