Lua-Async 协程的高级用法

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传送门

原文地址:https://www.cnblogs.com/mmc1206x/p/12057003.html

时间: 2024-10-01 11:13:11

Lua-Async 协程的高级用法的相关文章

Lua的协程和协程库详解

我们首先介绍一下什么是协程.然后详细介绍一下coroutine库,然后介绍一下协程的简单用法,最后介绍一下协程的复杂用法. 一.协程是什么? (1)线程 首先复习一下多线程.我们都知道线程——Thread.每一个线程都代表一个执行序列. 当我们在程序中创建多线程的时候,看起来,同一时刻多个线程是同时执行的,不过实质上多个线程是并发的,因为只有一个CPU,所以实质上同一个时刻只有一个线程在执行. 在一个时间片内执行哪个线程是不确定的,我们可以控制线程的优先级,不过真正的线程调度由CPU的调度决定.

lua的协程(coroutine)

协程和多线程下的线程类似:有自己的堆栈,自己的局部变量,有自己的指令指针,但是和其他协程程序共享全局变量等信息.线程和协程的主要不同在于:多处理器的情况下,概念上来说多线程是同时运行多个线程,而协程是通过协作来完成,任何时刻只有一个协程程序在运行.并且这个在运行的协程只有明确被要求挂起时才会被挂起 你可以使用coroutine.create来创建协程: co = coroutine.create(function () print("hi") end) 协程有三种状态:挂起,运行,停止

Lua中协程的使用

平常访问网络都会使用回调的方式,现在通过协程改变这种回调的模式,让异步方法按同步的方法来使用 -- co.lua yield = coroutine.yield co = function(func, cb) local cor = coroutine.create(func) local next = coroutine.resume local hasNext; hasNext = function(status, func, ...) -- suspended if not status

【Lua】协程的应用

前言 协程可以解决哪些编程问题? 生产者-消费者 生产者A做面条,消费者B吃面条.A做完面条,B吃面条,吃完了,A再做... 则,有两种模式: 在消费者B吃面的function中插入resume唤醒生产者A,A生产完后放置一个yield(面条),返回面条并暂停,B接到返回值(面条)后开始吃. 在生产者A生产的function中插入resume(面条)唤醒消费者B,B吃完后放置一个yield,暂停,A继续做面条. 可见,主循环放在B和A中都可以,一方为主,另一方为服务.

lua编程之协程介绍

一,lua协程简介 协程(coroutine),意思就是协作的例程,最早由Melvin Conway在1963年提出并实现.跟主流程序语言中的线程不一样,线程属于侵入式组件,线程实现的系统称之为抢占式多任务系统,而协程实现的多任务系统成为协作式多任务系统.线程由于缺乏yield语义,所以运行过程中不可避免需要调度,休眠挂起,上下文切换等系统开销,还需要小心使用同步机制保证多线程正常运行.而协程的运行指令系列是固定的,不需要同步机制,协程之间切换也只涉及到控制权的交换,相比较线程来说是非常轻便的.

Lua 协程coroutine

协程和一般多线程的区别是,一般多线程由系统决定该哪个线程执行,是抢占式的,而协程是由每个线程自己决定自己什么时候不执行,并把执行权主动交给下一个线程. 协程是用户空间线程,操作系统其存在一无所知,所以需要用户自己去做调度,用来执行协作式多任务非常合适. 线程和协同程序的主要不同在于:在多处理器情况下,多线程程序同时运行多个线程:而协同程序是通过协作来完成,在任一指定时刻只有一个协同程序在运行,并且这个正在运行的协同程序只在必要时才会被挂起.这样Lua的协程就不能利用现在多核技术了. (一)Cor

Lua 协程 coroutine

协程是协同程序的简称,顾名思义,就是协同工作的程序.协程拥有自己独立的桟.局部变量和PC计数器,同时又与其他协同程序共享全局变量和其他大部分东西: 协程与线程的主要区别在于,一个多线程程序可以同时运行几个线程(并发执行.抢占),而协同程序却需要彼此协作地运行,即一个多协程程序在任意时刻只能运行一个协程,并且正在执行的协程只会在其显式地要求挂起(suspend)时,它的执行才会暂停(无抢占.无并发). Lua中所有与协程相关的函数都在coroutine(一个table)中: 函数create用于创

Python核心技术与实战——十五|Python协程

我们在上一章将生成器的时候最后写了,在Python2中生成器还扮演了一个重要的角色——实现Python的协程.那什么是协程呢? 协程 协程是实现并发编程的一种方式.提到并发,肯很多人都会想到多线程/多进程模型,这就是解决并发问题的经典模型之一.在最初的互联网世界中,多线程/多进程就在服务器并发中起到举足轻重的作用. 但是随着互联网的发展,慢慢很多场合都会遇到C10K瓶颈,也就是同时连接到服务器的客户达到1W,于是,很多代码就跑崩溃,因为进程的上下文切换占用了大量的资源,线程也顶不住如此巨大的压力

Python函数进阶:闭包、装饰器、生成器、协程

返回目录 本篇索引 (1)闭包 (2)装饰器 (3)生成器 (4)协程 (1)闭包 闭包(closure)是很多现代编程语言都有的特点,像C++.Java.JavaScript等都实现或部分实现了闭包功能,很多高级应用都会依靠闭包实现. 一般专业文献上对闭包的定义都比较拗口,比如:“将组成函数的语句和这些语句的执行环境打包在一起时,得到的对象称为闭包.” 其实,简单来说,你可以将闭包看成是一个轻载的类,这个类只有一个函数方法,并且只有为数不多的几个成员变量. 闭包的优点是:实现起来比类稍微轻巧一