Lua-Async

这是一个基于协程的异步调用库, 该库的设计思路类似JavaScript的Promise, 但相比Promise, 它有更多的灵活性.

--  引入Async
local Async = require("Async") -- 创建Async
-- 可传递参数到接下来的调用中
Async.New(...) -- 注册异步调用
Async.New(...)
:Ok(function(ok, no, ...) return no() end) -- 在Ok管道注册回调, 之后进入No管道
:No(function(ok, no, ...) return ok() end) -- 在No管道注册回调, 之后进入Ok管道
:Ok(function(ok, no, ...) return no() end) -- 在Ok管道注册回调, 之后进入No管道
:No(function(ok, no, ...) return ok() end) -- 在No管道注册回调, 之后进入Ok管道 -- 异常捕获
Async.New(...)
:Error(function() print("捕获异常...") end) -- 注册异常捕获函数
:Ok(function(ok, no, ...) return no() end) -- 在Ok管道注册回调, 之后进入No管道
:No(function(ok, no, ...) return ok() end) -- 在No管道注册回调, 之后进入Ok管道
:Ok(function(ok, no, ...) return no() end) -- 在Ok管道注册回调, 之后进入No管道
:No(function(ok, no, ...) return ok() end) -- 在No管道注册回调, 之后进入Ok管道

JavaScript Promise 对比

Js版本

new Promise((resolve, reject) => {
resolve(); // 下一步
})
.then((resolve, reject) => {
reject(); // 下一步
})
.catch(() => {
// 异常处理
})

Lua版本

require("Async").New()
:Ok(function(ok, no)
return ok() -- 下一步
end)
:Ok(function(ok, no)
return no() -- 下一步
end)
:No(function(ok, no)
return no() -- 异常处理
end)

简单的使用例子

--  一个简易的定时器
local Timer = {
mTasks = {}
} -- 为定时器插入一个任务
function Timer:Insert(tick, func)
table.insert(self.mTasks, { mTick = os.clock() + tick, mFunc = func })
end -- 更新定时器
function Timer:Update(tick)
local dels = {}
local time = os.clock()
for k, task in pairs(self.mTasks) do
if task.mTick <= time then
table.insert(dels, k)
task.mFunc()
end
end for i, v in ipairs(dels) do
self.mTasks[v] = nil
end
end -- 3层嵌套异步调用
Timer:Insert(2, function()
print("clock: \t", os.date("%y-%m-%d %H:%M:%S"))
Timer:Insert(2, function()
print("clock: \t", os.date("%y-%m-%d %H:%M:%S"))
Timer:Insert(2, function()
print("clock: \t", os.date("%y-%m-%d %H:%M:%S"))
end)
end)
end) -- 通过Async 3层异步调用
require("Async").New()
:Ok(function(ok, no)
Timer:Insert(2, function() print("Async clock: ", os.date("%y-%m-%d %H:%M:%S")) ok() end)
end)
:Ok(function(ok, no)
Timer:Insert(2, function() print("Async clock: ", os.date("%y-%m-%d %H:%M:%S")) ok() end)
end)
:Ok(function(ok, no)
Timer:Insert(2, function() print("Async clock: ", os.date("%y-%m-%d %H:%M:%S")) ok() end)
end) while true do
Timer:Update(os.clock())
end **调用结果**
> C:\MyWork\Git\Lua-Async>lua demo.lua
> clock: 19-12-17 21:00:23
> Async clock: 19-12-17 21:00:23
> clock: 19-12-17 21:00:25
> Async clock: 19-12-17 21:00:25
> clock: 19-12-17 21:00:27
> Async clock: 19-12-17 21:00:27

调用结果

C:\MyWork\Git\Lua-Async>lua demo.lua

clock: 19-12-17 21:00:23

Async clock: 19-12-17 21:00:23

clock: 19-12-17 21:00:25

Async clock: 19-12-17 21:00:25

clock: 19-12-17 21:00:27

Async clock: 19-12-17 21:00:27

Github传送门

最新文章

  1. AFN和ASI区别
  2. first Automation
  3. Java Servlet系列之Servlet生命周期
  4. mysql启动错误与修复
  5. 用javascript 面向对象制作坦克大战(四)
  6. LDAP验证用户名和密码
  7. discuz!迁移指南
  8. 从零开始搭建Jenkins+Docker自动化集成环境
  9. 【Android Studio安装部署系列】二十、Android studio如何将so文件添加到svn中
  10. 数据库alert报错:ORA-00202、ORA-15081、ORA-27072
  11. Netty源码分析(一):Netty总览
  12. 安卓程序中手机后退键与标题栏后退键是不同的,前者回出发onBackPressed()函数,后者需要重重写temclick函数
  13. Codeforces Round #540 (Div. 3)
  14. Unity Chan 3D Asset
  15. 许仙章鱼TV
  16. summer_19th,Nov 2018
  17. iOS微信实现第三方登录的方法
  18. Sring类的codePointAt()方法
  19. sqlserver linux 容器运行
  20. 03 Maven 坐标与依赖

热门文章

  1. python的文件操作及简单的用例
  2. .net画二叉树
  3. VLAN实验(1)Access接口
  4. systemd概念和运行机制
  5. CSS RESET —— 浏览器样式重置
  6. PL真有意思(三):名字、作用域和约束
  7. 在input输入值改变reducer里的值
  8. 万恶之源-python加深
  9. GeoServer CQL查询时中文问题
  10. 关于Java中2.0-1.1!=0.9的问题