(Translated by https://www.hiragana.jp/)
GitHub - clksaaa/TimingWheel: c#版分层时间轮算法,参考kafka TimingWheel实现
Skip to content

c#はんぶん层时间轮算法さんぽう参考さんこうkafka TimingWheel实现

Notifications You must be signed in to change notification settings

clksaaa/TimingWheel

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 

Repository files navigation

TimingWheel

C#はんぶん层时间轮算法さんぽう参考さんこう kafka TimingWheel 实现。

NuGet

.NET Standard 2.0+
Install-Package TimingWheel.Net

使用しよう

// てい义一个秒级时间轮
var timer = TimingWheelTimer.Build(TimeSpan.FromSeconds(1), 60);
timer.Start();

// 添加てんかのべ时任务
var task1 = timer.AddTask(TimeSpan.FromSeconds(5), () =>
{
    Console.WriteLine($"{DateTime.Now}, Task1: 执行");
});
var task2 = timer.AddTask(TimeSpan.FromSeconds(5), () =>
{
    Console.WriteLine($"{DateTime.Now}, Task2: 执行");
    throw new Exception();
});

Console.WriteLine($"{DateTime.Now}, Task1: {task1.TaskStatus}");
Console.WriteLine($"{DateTime.Now}, Task2: {task2.TaskStatus}");

// とうまちいた执行
await Task.Delay(TimeSpan.FromSeconds(6));

Console.WriteLine($"{DateTime.Now}, Task1: {task1.TaskStatus}");
Console.WriteLine($"{DateTime.Now}, Task2: {task2.TaskStatus}");

timer.Stop();

// ひかえせいだい输出
11/5 ほしよん 14:48:25, Task1: Wait
11/5 ほしよん 14:48:25, Task2: Wait
11/5 ほしよん 14:48:30, Task1: 执行
11/5 ほしよん 14:48:30, Task2: 执行
11/5 ほしよん 14:48:31, Task1: Success
11/5 ほしよん 14:48:31, Task2: Fail

原理げんり

まち补充...

更新こうしんこころざし

v1.0.1更新こうしん内容ないよう
1、细分にん务状态

v1.0.2更新こうしん内容ないよう
1、sorry,拼写错误:TimeTaskStaus -> TimeTaskStatus

v1.0.3更新こうしん内容ないよう
1、おさむ复时间槽にゅう队时てき临界值bug

About

c#はんぶん层时间轮算法さんぽう参考さんこうkafka TimingWheel实现

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • C# 100.0%