源码阅读-GlobalTimer
程序员文章站
2022-04-23 19:58:26
最近看到一篇文章推了一个开源项目, "GlobalTimer" 。主要是可以用一个定时器来统一管理多个定时任务,可以针对特定任务进行管理。 一、原理 1.一个公共的timer 2.封装任务到自定义个Event中,保留任务的执行代码与数据,时间信息等 3.计算所有任务间隔的最大公约数x,用这个x作为t ......
最近看到一篇文章推了一个开源项目,GlobalTimer。主要是可以用一个定时器来统一管理多个定时任务,可以针对特定任务进行管理。
一、原理
1.一个公共的timer
2.封装任务到自定义个Event中,保留任务的执行代码与数据,时间信息等
3.计算所有任务间隔的最大公约数x,用这个x作为timer的触发间隔
4.timer触发时,遍历所有任务,看是否到了执行间隔来决定是否执行
二、记录点
1.最大公约数与最小公倍数计算公式
// 最大公约数 int gcd(int a, int b) { if (a == 0) return b; return gcd(b%a, a); }
// 最小公倍数 int lcm(int a, int b) { if (a == 0) return b; return a*b/gcd(b%a, a); }
2.Lock宏
#define LOCK(...) dispatch_semaphore_wait(_lock, DISPATCH_TIME_FOREVER); \ __VA_ARGS__; \ dispatch_semaphore_signal(_lock);
不过建议改成这样
#define LOCK(lock,...) do { \ dispatch_semaphore_wait(lock, DISPATCH_TIME_FOREVER); \ __VA_ARGS__; \ dispatch_semaphore_signal(lock); \ } while (0);
3.OSAtomic
类型 | |
---|---|
内存屏障 | OSMemoryBarrier() |
自旋锁 |
OSSpinLockLock , OSSpinLockTry , OSSpinLockUnlock
|
原子队列操作 | FIFO:OSAtomicFifoDequeue 和OSAtomicFifoEnqueue LIFO:OSAtomicDequeue和OSAtomicEnqueue |
比较和交换 |
OSAtomicCompareAndSwap**[Barrier] 如果是旧值,就替换,否则不变OSAtomicTestAndClear/OSAtomicTestAndClearBarrier 置0OSAtomicTestAndSet/OSAtomicTestAndSetBarrier 置1 |
布尔操作(AND, OR, XOR) |
OSAtomicAnd32 , OSAtomicAnd32Barrier , OSAtomicAnd32Orig , OSAtomicAnd32OrigBarrier
|
数学操作 | 加操作:OSAtomicAdd** , OSAtomicAdd**Barrier 递减操作: OSAtomicDecrement** , OSAtomicDecrement**Barrier 递增操作: OSAtomicIncrement** , OSAtomicIncrement**Barrier
|
三、其他
相关吐槽其实已经提了issue,看到最后发现他的代码参考了不少MSWeakTimer的代码。
上一篇: Oracle连接远程数据库的四种方法
推荐阅读
-
九、Spring之BeanFactory源码分析(一)
-
Spring源码分析之IoC容器初始化
-
Mybaits 源码解析 (八)----- 全网最详细,没有之一:结果集 ResultSet 自动映射成实体类对象(上篇)
-
Mybaits 源码解析 (九)----- 全网最详细,没有之一:一级缓存和二级缓存源码分析
-
建议收藏:.net core 使用EPPlus导入导出Excel详细案例,精心整理源码已更新至开源模板
-
JDK源码分析-HashMap
-
SpringBoot爬虫小说阅读网站,定时更新小说和抓取功能
-
asp.net abp模块化开发之通用树2:设计思路及源码解析
-
SSM框架整合 详细步骤(备注) 附源码
-
在Windows系统中构建还原ASP.NET Core 源码