Lua | 每日一练 (4)

💢欢迎来到张胤尘的技术站
💥技术如江河，汇聚众志成。代码似星辰，照亮行征程。开源精神长，传承永不忘。携手共前行，未来更辉煌💥

文章目录

  • Lua | 每日一练 (4)
    • 题目
    • 参考答案
      • 线程和协程
        • 调度方式
        • 上下文切换
        • 资源占用
        • 实现机制
        • 使用场景
      • `lua` 中的协程
        • 协程的生命周期
        • 主要函数
          • 创建协程
          • 启动或恢复协程
          • 检查当前是否在主协程中运行
          • 暂停协程
          • 检测协程是否可暂停
          • 获取协程状态
          • 包装函数
          • 关闭协程
        • 具体使用

Lua | 每日一练 (4)

题目

协程和线程有何区别？简述 lua 中的协程。

参考答案

线程和协程

协程和线程虽然在某些方面有相似之处，但它们在设计目标、实现原理和使用方式上有很大的区别。下面从调用方式、上下文切换、资源使用、实现机制、使用场景这几个方面进行阐述。

调度方式
  • 线程：线程的执行由操作系统内核控制，操作系统会根据调度算法（如时间片轮转、优先级调度等）自动切换线程的执行。另外，线程的切换时间点不可预测，程序无法直接控制线程的暂停和恢复。
  • 协程：协程的执行由程序显式控制，需要开发者通过 coroutine.yield 和 coroutine.resume 显式地暂停和恢复协程。协程的切换完全由程序逻辑决定，切换点是明确的。
上下文切换
  • 线程：线程切换涉及操作系统内核的上下文切换，需要保存和恢复线程的寄存器状态、栈信息等，开销较大。
  • 协程：协程的上下文切换在用户态完成，不需要操作系统内核介入，开销非常小。
资源占用
  • 线程：每个线程都有自己的栈空间，通常默认分配 8 MB，资源占用较大。如果线程数量过多会导致系统资源耗尽。
$ ulimit -s
8192
  • 协程：协程的栈空间是动态分配的，通常占用较少的内存。另外，协程的数量可以非常大，适合处理大规模的并发任务。
实现机制
  • 线程：线程是操作系统提供的并发机制，由操作系统内核管理。线程的创建和销毁需要系统调用，涉及内核态和用户态的切换。
  • 协程：协程是语言层面的机制，由 lua 解释器实现。协程的创建和切换完全在用户态完成，不涉及操作系统内核。
使用场景
  • 线程：适合处理真正的并发任务，例如多核 CPU 上的并行计算，处理 I/O 密集型任务。
  • 协程：适合处理单核 CPU 上的并发任务，尤其是需要频繁切换的场景；适合实现非阻塞 I/O 操作，例如网络编程中的异步请求处理。

lua 中的协程

在 lua 中，协程是实现异步编程的核心工具之一。由于 lua 本身没有内置的多线程支持，而协程提供了一种轻量级的并发机制，可以用来模拟异步操作，从而实现非阻塞的程序设计。

协程的生命周期

lua 协程的生命周期包括以下几个阶段：

  • 创建：使用 coroutine.create 创建一个协程。此时协程处于挂起状态，尚未开始执行。
  • 运行：使用 coroutine.resume 启动或恢复协程的执行。
  • 暂停：在协程执行过程中，可以通过 coroutine.yield 暂停协程的执行，将控制权交回主程序。
  • 结束：当协程运行完成或因错误终止时，协程进入结束状态。

协程的状态之间切换，如下图所示：

在这里插入图片描述

主要函数

下面介绍 lua 中关于协程的主要函数。

创建协程
local co = coroutine.create(f)
  • f：协程函数，表示协程的主体逻辑。
  • 返回一个协程对象 co，类型为 thread。协程对象可以用于后续的 coroutine.resume 和 coroutine.yield 等操作。

例如：

-- func 是协程函数，主体逻辑
local function func()print("Coroutine is running")
end-- 创建协程
local co = coroutine.create(func)
print(co) -- thread: 0x60f0c8666df8
启动或恢复协程
ok, ... = coroutine.resume(co, ...)
  • co：要启动或者恢复的协程对象。
  • ...：可选参数，这些参数会传递给协程中的 coroutine.yield 或协程的入口函数。
  • ok：布尔值，表示协程是否成功恢复。如果协程因错误终止，返回 false。
  • ...：协程中 coroutine.yield 的返回值。如果协程运行完成，返回值为 nil。

说明：

  • 如果协程处于 suspended 状态，coroutine.resume 会启动或恢复协程的执行。
  • 如果协程已经处于 running 状态，调用 coroutine.resume 会抛出错误。
  • 如果协程已经处于 dead 状态，调用 coroutine.resume 也会抛出错误。

例如：

local function func(x, y)print("Coroutine started with:", x, y) -- Coroutine started with:	10	20
endlocal co = coroutine.create(func)local ok, result = coroutine.resume(co, 10, 20)
print(ok, result) -- true	nil
检查当前是否在主协程中运行
current_co, is_main = coroutine.running()
  • current_co：当前运行的协程对象。
  • is_main：布尔值，表示当前是否在主协程中运行，如果是主协程返回 true，否则返回 false。

说明：

  • 用于检查当前是否在主协程中运行，以及当前协程是否是主线程。

例如：

local function printCurrentCoroutine()local current_co, is_main = coroutine.running()print(current_co, is_main)
endprintCurrentCoroutine() -- thread: 0x61617e0492a8	truelocal co = coroutine.create(function()print("Printing from the coroutine") -- Printing from the coroutineprintCurrentCoroutine()              -- thread: 0x61617e04fec8	false
end)coroutine.resume(co) -- 启动协程
暂停协程
... = coroutine.yield(...)
  • ...：可选参数，这些参数会传递给调用 coroutine.resume 的代码。
  • 返回值是 coroutine.resume 调用时传递的参数。

说明：

  • coroutine.yield 用于暂停当前协程的执行，并将控制权返回给调用 coroutine.resume 的代码。
  • 协程暂停后，可以通过再次调用 coroutine.resume 恢复执行。

例如：

local function func()print("Coroutine running")              -- Coroutine runninglocal value = coroutine.yield("Yielded value")print("Coroutine resumed with:", value) -- Coroutine resumed with:	Hello
endlocal co = coroutine.create(func)
local ok, result = coroutine.resume(co)
print(ok, result) -- true	Yielded valuelocal ok, result = coroutine.resume(co, "Hello")
print(ok, result) -- true	nil
检测协程是否可暂停
is_yieldable = coroutine.isyieldable([co])
  • co：可选参数，表示要检查的协程对象。默认为当前运行的协程。
  • is_yieldable：布尔值，表示协程是否可以暂停。

说明：

  • 如果协程不是主协程且不在非可暂停的 C 函数中，则返回 true。
  • 主协程调用时返回 false。
  • 协程处于 suspended、dead 状态时 coroutine.isyieldable 仍然返回 true，因为协程对象本身仍然是有效的，并且在 lua 的语义中，dead 状态的协程仍然可以被认为是可以暂停的（尽管它已经无法再被恢复）。

例如：

local co = coroutine.create(function()print(coroutine.isyieldable()) -- truecoroutine.yield()
end)coroutine.resume(co)             -- 启动协程
print(coroutine.isyieldable(co)) -- true
print(coroutine.status(co))      -- suspended
coroutine.resume(co)
print(coroutine.status(co))      -- dead
print(coroutine.isyieldable(co)) -- true
print(coroutine.isyieldable())   -- false
获取协程状态
status = coroutine.status(co)
  • co：要检查状态的协程对象。
  • 返回一个字符串，表示协程的当前状态：
    • `running：协程正在运行。
    • suspended：协程处于暂停状态。
    • dead：协程已经运行完成或因错误终止。
    • normal：协程尚未启动（初始状态）。

例如：

local function func(co)local status = coroutine.status(co)print(status) -- runningcoroutine.yield("hello, world!")
endlocal co = coroutine.create(func)
local status = coroutine.status(co)
print(status) -- suspendedlocal ok, result = coroutine.resume(co, co)
print(ok, result) -- true	hello, world!local ok, result = coroutine.resume(co, co)
print(ok, result) -- true	nillocal status = coroutine.status(co)
print(status) -- dead
包装函数
f = coroutine.wrap(f)
  • f：协程函数，表示协程的主体逻辑。
  • 返回一个包装函数 f。调用这个包装函数时，会自动启动或恢复协程的执行。

说明：

  • coroutine.wrap 是 coroutine.create 和 coroutine.resume 的简化版本。
  • 包装函数的返回值是协程中 coroutine.yield 的参数。
  • 如果协程运行完成，包装函数返回 nil；如果协程因错误终止，会抛出错误。

例如：

local wrapped = coroutine.wrap(function()print("Coroutine running")local value = coroutine.yield("Yielded value")print("Coroutine resumed with:", value)
end)local result = wrapped()
print(result)    -- Yielded valuewrapped("Hello") -- Coroutine resumed with:	Hello
关闭协程
ok, err = coroutine.close(co)

  • co：要关闭的协程对象，协程的状态必须是 suspended 或 dead 状态。

  • ok：布尔值，表示操作是否成功。

  • err：如果操作失败，返回错误信息。

说明：

  • 关闭协程 co，将其状态设置为 dead，并关闭协程中所有待关闭的变量。
  • 如果协程已经是 dead 状态，调用 coroutine.close 会返回 true。

例如：

local co = coroutine.create(function()coroutine.yield() -- 暂停协程
end)coroutine.resume(co)                -- 启动协程
print(coroutine.status(co))         -- suspendedlocal ok, err = coroutine.close(co) -- 关闭协程
print(ok, err)                      -- true	nil
print(coroutine.status(co))         -- dead
具体使用

使用协程实现经典的生产者-消费者模型。协程的暂停和恢复特性非常适合这种场景，因为生产者和消费者可以分别在协程中运行，通过共享队列进行通信。

一个简单的生产者-消费者模型实现，如下所示：

-- 队列实现
local Queue = {}function Queue:new()local obj = {}setmetatable(obj, self)self.__index = selfobj.list = {}return obj
endfunction Queue:put(item)table.insert(self.list, item)
endfunction Queue:get()if #self.list <= 0 thenreturn nilendlocal item = self.list[1]table.remove(self.list, 1)return item
endfunction Queue:is_empty()return #self.list == 0
end-- 生产者函数
local function producer(queue, count)for i = 1, count doprint("Produced:", i)queue:put(i)coroutine.yield()end
end-- 消费者函数
local function consumer(queue, count)for i = 1, count dowhile queue:is_empty() doprint("Waiting for item...")coroutine.yield()endlocal item = queue:get()print("Consumed:", item)end
endlocal queue = Queue:new()
local count = 100 -- 生产/消费数量-- 创建生产者和消费者协程
local co_producer = coroutine.create(function()producer(queue, count)
end)local co_consumer = coroutine.create(function()consumer(queue, count)
end)-- 同时运行生产者和消费者协程
while coroutine.status(co_producer) ~= "dead" or coroutine.status(co_consumer) ~= "dead" doif coroutine.status(co_producer) ~= "dead" thencoroutine.resume(co_producer)endif coroutine.status(co_consumer) ~= "dead" thencoroutine.resume(co_consumer)end
end

🌺🌺🌺撒花！

如果本文对你有帮助，就点关注或者留个👍
如果您有任何技术问题或者需要更多其他的内容，请随时向我提问。

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/27458.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

数据结构：二叉搜索树（排序树）

数据结构：二叉搜索树（排序树）

1.二叉搜索树的定义 二叉搜索树要么是空树&#xff0c;要么是满足以下特性的树 &#xff08;1&#xff09;左子树不为空&#xff0c;那么左子树左右节点的值都小于根节点的值 &#xff08;2&#xff09;右子树不为空&#xff0c;那么右子树左右节点的值都大于根节点的值 &#…
阅读更多...
SpringBoot快速入门

SpringBoot快速入门

快速入门 1). 创建springboot工程&#xff0c;并导入 mybatis的起步依赖、mysql的驱动包、lombok等。 项目工程创建完成后&#xff0c;自动在pom.xml文件中&#xff0c;导入Mybatis依赖和MySQL驱动依赖。如下所示&#xff1a; 2). 数据准备&#xff1a;创建用户表user&#xf…
阅读更多...
DataWorks (数据工厂)介绍

DataWorks (数据工厂)介绍

介绍 DataWorks 是阿里云推出的一体化大数据开发与治理平台&#xff0c;曾用名"数据工厂""大数据开发套件" 最新版本是3.0 它是一套基于MaxCompute&#xff08;原ODPS&#xff09;的DW(数据仓库)解决方案&#xff0c;它集成了阿里多年的DW实施经验&…
阅读更多...
信息技术知识赛系统设计与实现(代码+数据库+LW)

信息技术知识赛系统设计与实现(代码+数据库+LW)

摘 要 传统办法管理信息首先需要花费的时间比较多&#xff0c;其次数据出错率比较高&#xff0c;而且对错误的数据进行更改也比较困难&#xff0c;最后&#xff0c;检索数据费事费力。因此&#xff0c;在计算机上安装信息技术知识赛系统软件来发挥其高效地信息处理的作用&…
阅读更多...
VirtualBox虚拟机转VM虚拟机

VirtualBox虚拟机转VM虚拟机

前言&#xff1a;部分靶机只适用于VirtualBox&#xff0c;VM打不开VirtualBox的文件&#xff0c;所以需要进行转换 前置条件&#xff1a;本机已经下载VM和VirtualBox 第一步&#xff1a;文件转换 找到VirtualBox.exe所在位置&#xff0c;启动cmd窗口 文件转换的命令&#xf…
阅读更多...
ArcGIS操作：11 计算shp矢量面的质心坐标

ArcGIS操作：11 计算shp矢量面的质心坐标

1、打开属性表 2、添加字段 3、设置字段名称、类型 4、选择创建的字段&#xff0c;计算几何 5、选择属性质心的x坐标、坐标系&#xff08;y坐标同理&#xff09; 注意&#xff1a;计算坐标一般使用的是地理坐标系&#xff08;投影坐标系转地理坐标系教程&#xff1a;ArcGIS操作…
阅读更多...
使用 DeepSeek 生成流程图、甘特图与思维导图：结合 Typora 和 XMind 的高效工作流

使用 DeepSeek 生成流程图、甘特图与思维导图：结合 Typora 和 XMind 的高效工作流

在现代工作与学习中&#xff0c;可视化工具如流程图、甘特图和思维导图能够极大地提升信息整理与表达的效率。本文将详细介绍如何使用 DeepSeek 生成 Mermaid 文本&#xff0c;结合 Typora 快速生成流程图和甘特图&#xff0c;并通过 Markdown 格式生成思维导图&#xff0c;最终…
阅读更多...
【Cadence仿真学习笔记】ADS Dynamic Link报错model is reserved的解决办法

【Cadence仿真学习笔记】ADS Dynamic Link报错model is reserved的解决办法

首先创建好原理图 创建symbol 在library manager下就会出现symbol了 在Cadence的CIW窗口中运行ADS dynamic link 打开ADS后&#xff0c;创建对应的cellview 加入控件OPTIONS 加入网表netlist 这个时候的Netlist没有路径 点击加载symbol 把原来的netlist include删掉…
阅读更多...
【二.提示词工程与实战应用篇】【1.提示词工程入门：AI对话的艺术】

【二.提示词工程与实战应用篇】【1.提示词工程入门：AI对话的艺术】

大家好，今天咱们来聊聊一个特别有意思的话题——提示词工程。你可能已经听说过这个词，或者在使用AI工具时不经意间接触过它。但提示词工程到底是什么？它为什么这么重要？咱们今天就来深入探讨一下，看看它是如何影响我们与AI的对话，以及如何在实际应用中发挥作用的。 什么…
阅读更多...
[密码学实战]Java实现国密（SM2）密钥协商详解：原理、代码与实践

[密码学实战]Java实现国密（SM2）密钥协商详解：原理、代码与实践

一、代码运行结果 二、国密算法与密钥协商背景 2.1 什么是国密算法&#xff1f; 国密算法是由中国国家密码管理局制定的商用密码标准&#xff0c;包括&#xff1a; SM2&#xff1a;椭圆曲线公钥密码算法&#xff08;非对称加密/签名/密钥协商&#xff09;SM3&#xff1a;密码…
阅读更多...
unity lua属性绑定刷新

unity lua属性绑定刷新

我们现在有一个 角色属性类叫heroModel,内容如下,当heroModel中的等级发生变化的时候&#xff0c;我们需要刷新界面显示等级信息&#xff0c;通常我们是在收到等级升级成功的协议的时候&#xff0c;发送一个事件&#xff0c;UI界面接受到这个事件的时候&#xff0c;刷新一下等级…
阅读更多...
制服小程序的“滑手”：禁用页面左右滑动全攻略

制服小程序的“滑手”：禁用页面左右滑动全攻略

哈哈&#xff0c;看来你已经很聪明地发现了小程序中左右滑动的“顽皮”行为&#xff01;&#x1f604; 没错&#xff0c;我们可以通过设置 disableScroll 属性来“管教”它&#xff0c;同时结合 CSS 样式让页面既禁得住横向“乱跑”&#xff0c;又能顺畅地上下滚动。你的方案已…
阅读更多...
蓝桥备赛（六）- C/C++输入输出

蓝桥备赛（六）- C/C++输入输出

一、OJ题目输入情况汇总 OJ&#xff08;online judge&#xff09; 接下来会有例题 &#xff0c; 根据一下题目 &#xff0c; 对这些情况进行分析 1.1 单组测试用例 单在 --> 程序运行一次 &#xff0c; 就处理一组 练习一&#xff1a;计算 (ab)/c 的值 B2009 计算 (ab)/c …
阅读更多...
Golang的性能分析指标解读

Golang的性能分析指标解读

Golang的性能分析指标解读 一、概述 语言&#xff09;是一种由Google开发的开源编程语言&#xff0c;以其并发性能和高效的编译速度而闻名。对于程序员来说&#xff0c;了解如何对Golang应用程序进行性能分析是非常重要的&#xff0c;因为这能帮助他们发现潜在的性能瓶颈并对其…
阅读更多...
【前端基础】Day 8 H5C3提高

【前端基础】Day 8 H5C3提高

目录 1. HTML5新特性 1.1 新增语义化标签 1.2 新增多媒体标签 1.3 新增input类型 1.4 新增表单属性 2. CSS3的新特性 2.1 新增选择器 2.1.1 属性选择器 2.1.2 结构伪类选择器 2.1.3 伪元素选择器&#xff08;重点&#xff09; 2.2 CSS3盒子模型 2.3 CSS3其他特性&a…
阅读更多...
Android系统_Surface绘制流程

Android系统_Surface绘制流程

目录 一,框架图 二,核心代码 一,框架图 对上面这张图的总结 二,核心代码 /Volumes/aosp/android-8.1.0_r52/frameworks/native/services/surfaceflinger/SurfaceFlinger.cpp void SurfaceFlinger::onMessageReceived(int32_t what) {ATRACE_CALL();switch (what) {case Mes…
阅读更多...
CDefView::_OnFSNotify函数分析

CDefView::_OnFSNotify函数分析

进入CDefView::_OnFSNotify函数时状态栏 _UpdateStatusBar函数之后增加一个对象&#xff0c;变成7个对象。 LRESULT CDefView::_OnFSNotify(LONG lNotification, LPCITEMIDLIST* ppidl) { LPITEMIDLIST pidl; LPCITEMIDLIST pidlItem; // we may be registered for no…
阅读更多...
KVMOVS组网配置案例-4

KVMOVS组网配置案例-4

0.配置要求 1.使用ovs创建一个网桥&#xff0c;网桥上添加宿主机eth0接口&#xff0c;接口为trunk,可转发所有vlan的数据2.使用KVM创建并图形安装两个linux虚拟机vm1,vm2。3.vm1关联ovs的vlan10接口&#xff0c;vm2关联ovs的vlan20接口。4.vm1获取vlan10的IP地址&#xff0c;v…
阅读更多...
C#—Settings配置详解

C#—Settings配置详解

C#—Settings配置详解 在C#项目中&#xff0c;全局配置通常指的是应用程序的设置&#xff08;settings&#xff09;&#xff0c;这些设置可以跨多个类或组件使用&#xff0c;并且通常用于存储应用程序的配置信息&#xff0c;如数据库连接字符串、用户偏好设置等。 Settings配置…
阅读更多...
Redis 哨兵模式

Redis 哨兵模式

哨兵模式&#xff08;Sentinel&#xff09; 是 Redis 提供的一种高可用性&#xff08;High Availability, HA&#xff09;解决方案&#xff0c;用于监控和管理 Redis 主从架构中的主节点&#xff08;Master&#xff09;和从节点&#xff08;Slave&#xff09;。当主节点出现故障…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023