一直找不到合适的 Go 时间轮库,正好工作需要,就自己实现了一个
1
aliipay 1 天前
想知道多个 Level 时候,最上层 level 到期后(比如 23 点 59 分 59 秒),大量任务需要重新分配 bucket ,如何保证系统平稳呢?
|
2
momowei 1 天前 ![]() 时间轮主要用来解决啥问题
|
3
phatzhong24 1 天前
@momowei #2 定时任务?
|
![]() |
4
dlmy 1 天前 ![]() |
![]() |
9
nobot 1 天前
这个不是顺手就来的吗?没个项目中都要收录一个,C++版,go 版,C#版,php 版
|
![]() |
11
BBCCBB 1 天前
看 kafka 的源码, 2, 300 行代码就能撸一个出来.
|
![]() |
13
IIInsomnia OP @aliipay 每次到点,都是将目标槽位的链表摘下,换一个新的上去;异步处理摘下的链表中的任务,互不影响
|
14
aliipay 20 小时 56 分钟前
@IIInsomnia 如果任务数量巨大,怎么保证能在一个最小定时间隔周期内完成呢,如果完不成就可能会导致任务丢失或者推迟到下一个分层完成
|
![]() |
15
IIInsomnia OP @aliipay 并发执行的,每个任务的执行都是独立的,且只会在最小的那个分层执行
|
![]() |
16
IIInsomnia OP @aliipay 时间轮是保证任务到时间被执行即可,至于执行多久跟时间轮无关了
|
17
jones2000 11 小时 31 分钟前
任务优先级没有体现出来, 当来了一个优先级很高的任务,如果机器 CPU , 内存使用多, 会导致优先级高的任务,无法快速完成, 需要把正在执行的低优先级任务的中间数据和状态存盘,停止这个任务,释放内存。 当高优先级任务执行完成以后, 在从文件里面恢复低优先级任务执行,继续执行。
|