异步

目录 正文 1. 如何获取当前任务 2. 如何获取所有任务 正文 我们可以反省在 asyncio 事件循环中运行的任务。这可以通过为当前运行的任务和所有正在运行的任务获取一个 asyncio.Task 对象来实现。 1. 如何获取当前任务 我们可以通过 asyncio.curre »

目录 正文 1. 什么是 Asyncio gather() 2. 如何使用 Asyncio gather() 3. 列表中多个协程的 gather() 示例 正文 asyncio 的一个好处是我们可以同时运行许多协程。这些协同程序可以在一个组中创建并存储，然后同时一起执行。这可以使用 »

目录 正文 1. 什么是 Asyncio gather() 2. 如何使用 Asyncio gather() 3. 列表中多个协程的 gather() 示例 正文 asyncio 的一个好处是我们可以同时运行许多协程。这些协同程序可以在一个组中创建并存储，然后同时一起执行。这可以使用 »

目录 正文 1. 什么是 Asyncio wait_for() 2. 如何使用 Asyncio wait_for() 3. 带有超时的 Asyncio wait_for() 示例 正文 我们可以使用 asyncio.wait_for() 函数等待 asyncio 任务或协程超时完成。如 »

目录 正文 1. 什么是 Asyncio wait_for() 2. 如何使用 Asyncio wait_for() 3. 带有超时的 Asyncio wait_for() 示例 正文 我们可以使用 asyncio.wait_for() 函数等待 asyncio 任务或协程超时完成。如 »

目录 正文 1. 什么是 asyncio.wait() 2. 如何使用 asyncio.wait() 3. 等待所有任务的示例 正文 我们可以通过 asyncio.wait() 函数等待异步任务完成。可以等待不同的条件，例如所有任务完成、第一个任务完成以及第一个任务因异常而失败。 让 »

目录 正文 1. 什么是 Asyncio shield() 2. 如何使用 Asyncio shield() 3. 示例 正文 Asyncio 任务可以通过调用它们的 cancel() 方法来取消。我们可以通过将任务包装在对 asyncio.shield() 的调用中来保护任务不被取消 »

目录 正文 1. 什么是异步迭代器 1.1. Iterators 1.2. Asynchronous Iterators 2. 什么是“async for”循环？ 3. 如何使用异步迭代器 4. 异步迭代器示例 正文 迭代是 Python 中的基本操作。我们可以迭代列表、字符 »

目录 正文 1. 什么是异步上下文管理器 1.1. Context Manager 1.2. Asynchronous Context Manager 2. 如何使用异步上下文管理器 2.1. 定义 2.2. 使用 3. 异步上下文管理器和“异步”示例 正文 上下文管理器是一 »

目录 正文 1. 什么是异步上下文管理器 1.1. Context Manager 1.2. Asynchronous Context Manager 2. 如何使用异步上下文管理器 2.1. 定义 2.2. 使用 3. 异步上下文管理器和“异步”示例 正文 上下文管理器是一 »

目录 引言 1. 什么是异步推导式 2. 推导式 3. 异步推导式 4. Await 推导式 引言 当我们想到“pythonic”时，理解，如列表和字典理解是 Python 的一个特性。 这是我们执行循环的一种方式，与许多其他语言不同。 Asyncio 允许我们使用异步推导式。 »

目录 1.应用场景 2.延时处理方式调研 1.DelayQueue 2.延迟队列mq 3.定时任务 4.redis 5. 时间轮 3.实现目标 4.架构设计 5.延迟组件实现方式 1.实现原理 2.消息结构 3.数据流转及流程图 6.demo示例 增加配置文件 配置 消费代码 注解形 »

目录 1.应用场景 2.延时处理方式调研 1.DelayQueue 2.延迟队列mq 3.定时任务 4.redis 5. 时间轮 3.实现目标 4.架构设计 5.延迟组件实现方式 1.实现原理 2.消息结构 3.数据流转及流程图 6.demo示例 增加配置文件 配置 消费代码 注解形 »

目录 1. 异步流 2. 如何打开连接 3. 如何启动服务器 4. 如何使用 StreamWriter 写入数据 5. 如何使用 StreamReader 读取数据 6. 如何关闭连接 1. 异步流 asyncio 的一个主要好处是能够使用非阻塞流。 Asyncio 提供非阻塞 I/ »

目录 1. 异步流 2. 如何打开连接 3. 如何启动服务器 4. 如何使用 StreamWriter 写入数据 5. 如何使用 StreamReader 读取数据 6. 如何关闭连接 1. 异步流 asyncio 的一个主要好处是能够使用非阻塞流。 Asyncio 提供非阻塞 I/ »

目录 1. 什么是 asyncio.subprocess.Process 2. 如何直接运行命令 2.1. 如何使用 Asyncio create_subprocess_exec() 2.2. Asyncio create_subprocess_exec() 示例 3. 如何通过 Shell »

目前系统中有很多需要用到延时处理的功能：支付超时取消、排队超时、短信、微信等提醒延迟发送、token刷新、会员卡过期等等。通过延时处理，极大的节省系统的资源，不必轮询数据库处理任务。 目前大部分功能通过定时任务完成，定时任务还分使用quartz及xxljob两种类型轮询时间短，每秒执行一次，对数据 »

目前系统中有很多需要用到延时处理的功能：支付超时取消、排队超时、短信、微信等提醒延迟发送、token刷新、会员卡过期等等。通过延时处理，极大的节省系统的资源，不必轮询数据库处理任务。 目前大部分功能通过定时任务完成，定时任务还分使用quartz及xxljob两种类型轮询时间短，每秒执行一次，对数据 »

目录 前言 实现步骤 自定义异步任务执行器和异常处理 @Async如何工作的 总结 前言 SpringBoot想必大家都用过，但是大家平时使用发布的接口大都是同步的，那么你知道如何优雅的实现异步呢？ 这篇文章就是关于如何在Spring Boot中实现异步行为的。但首先，让我们看看同步和异 »

目录 前言 实现步骤 自定义异步任务执行器和异常处理 @Async如何工作的 总结 前言 SpringBoot想必大家都用过，但是大家平时使用发布的接口大都是同步的，那么你知道如何优雅的实现异步呢？ 这篇文章就是关于如何在Spring Boot中实现异步行为的。但首先，让我们看看同步和异 »