1.UE4源码剖析——异步与并行 中篇 之 Thread
2.c++基础语法之future，源用promise，码使async详细讲解-SurfaceFlinger学习必备c++知识
3.Rust Async: smol源码分析-Executor篇
4.async-validator源码解析（四）：Schema类
5.Async、源用Await 从源码层面解析其工作原理
6.Vue3源码系列 (九)：异步组件 defineAsyncComponent 与 Suspense

UE4源码剖析——异步与并行 中篇 之 Thread

       我们知道UE中的码使异步框架分为TaskGraph与Thread两种，上篇教程我们学习了TaskGraph，源用它擅长处理有依赖关系的码使1001的源码短任务；本篇教程我们将学习Thread，它与TaskGraph相反，源用它更擅长于处理长任务。码使而下一篇文章，源用我们则会承接Thread，码使去学习一下引擎中一些重要的源用线程。

       Thread擅长处理长任务，码使从长任务生命周期这个层面来看，源用我们可以先把长任务分为两类：常驻型长任务与非常驻型长任务。码使

       常驻型长任务侧重于并行，源用通常用于监听式服务，例如网络传输，使用单独的线程对网络进行监听，每当有网络数据包到达时，线程接收并处理后，不会立即结束，而是重置部分状态，继续监听，等待下一轮数据包。

       非常驻型长任务侧重于异步，通常用于数据处理，例如主线程为了提高性能，避免卡顿，会将一些重负载的运算任务分发给分线程处理，可能分批给多条分线程，主线程继续运行其他逻辑。任务处理完成后，将结果返回给主线程，分线程可销毁。

       接下来，我们通过两个例子学习Thread的使用。

       计算由N到M（N和M为大数字）所有数字的和。使用Thread异步调用，将计算操作交由分线程执行，计算完成后再通知主线程结果，代码实现如下：

       逻辑分为两部分：启动分线程计算数字和，使用Async函数，参数为EAsyncExecution::Thread，创建新线程执行。学习Async函数用法，该函数返回TFuture对象，代表未来状态，cocos源码购买当前无法获取结果，但在未来某个时刻状态变为Ready，此时可通过TFuture获取结果。

       主线程注册回调，等待分线程计算完成，使用TFuture的Then函数，完成时触发注册的回调，也可使用Wait系列函数等待计算完成。

       接下来学习常驻型任务使用。

       定义玩家血量上限点，当前点，当血量未满时，每0.2秒恢复1点血量。代码实现分为创建生命治疗仪FRunnable对象、重写Run函数、创建FRunnableThread线程、测试恢复功能和释放线程资源。

       生命治疗仪创建与测试完整代码如下，可验证生命恢复功能和暂停与恢复。

       UE4中的FRunnable与FRunnableThread提供创建常驻型任务所需接口。无论是常驻型还是非常驻型，底层实现相同，都是使用FRunnableThread线程。

       FRunnableThread线程结构包含标识符、逻辑功能、效率与性能、辅助调试字段。线程创建与生命周期分为创建FRunnable类对象、创建FRunnableThread对象两步，通过FRunnable的生命周期管理实现线程运行与停止。

       UE4线程管理流程包括继承并创建FRunnable类对象、创建FRunnableThread对象，生命治疗仪线程创建代码。

       UE4中的几种异步方式底层使用线程实现，学习了线程类型、创建、生命周期、销毁方法，为下篇学习引擎特殊线程打下基础。

c++基础语法之future，promise，async详细讲解-SurfaceFlinger学习必备c++知识

       在SurfaceFlinger源码分析中，我遇到了一些新的C++基础语法，比如future和promise。这些工具的引入，使得在多线程环境中访问异步操作的404好看源码结果变得更加方便。

       传统上，在C++中，我们需要通过创建线程并使用`join`等待线程完成，然后将结果赋值给变量。这种过程相对繁琐。为了解决这个问题，C++引入了`std::future`来访问异步操作的结果。`future`类不能立即获取结果，而是在异步操作完成后，通过同步等待或者查询状态来获取结果。`future`的状态有三种：未开始（`future_status::deferred`）、已完成（`future_status::ready`）、超时（`future_status::timeout`）。

       `std::async`函数用于创建异步任务，结果保存在`future`对象中。当需要获取异步结果时，通过`future.get()`方法来完成。如果只关注任务完成，可以使用`future.wait()`方法。`async`函数的参数包括线程创建策略（如`std::launch::async`、`std::launch::deferred`）、要执行的函数和函数执行时需要传递的参数。

       `std::promise`类帮助线程赋值。在线程函数中，通过`promise`对象的`set_value`方法为外部传递的`promise`赋值。在任务完成后，可以通过`promise`对象关联的`future`获取设置的值。

       在实际应用中，`promise`和`future`的结合使得在多线程环境下访问异步操作的结果更加灵活。例如，在SurfaceFlinger源码中，`future`用于等待子线程执行完成，并通过`set_value`设置结果，`get`方法用于获取结果。这种结合使得源码分析更加简便。

       为了深入理解这些新语法，我查阅了相关文档，并实践了在SurfaceFlinger源码中的应用。同时，我还使用了性能分析工具如`perfetto`和`systrace`来验证代码的运行效果。这些实践不仅帮助我学习了C++的新语法，还加深了对SurfaceFlinger源码的理解。

       如果你对这些C++基础语法感兴趣，或者想要了解SurfaceFlinger源码的详细分析，可以参考我的视频教程，或者私聊我进行深入探讨。数浪源码我的文章和视频内容涵盖了C++基础语法的学习，以及如何将其应用于实际的SurfaceFlinger源码分析。

Rust Async: smol源码分析-Executor篇

       本文深入探讨了smol异步运行时中的Executor组件，尤其关注了Executor的实现细节。在smol的异步框架中，Executor扮演了核心角色，主要负责执行Future，并在多线程环境中调度和管理任务。

       Executor分为三种类型：ThreadLocalExecutor、Blocking Executor、Work Stealing Executor。ThreadLocalExecutor用于处理不能实现Send特性的Future，通过使用并发和非并发队列，减少了跨线程的同步开销。Blocking Executor则允许执行阻塞任务，并通过动态地开启线程来应对任务的增加，从而提高了资源的利用率。Work Stealing Executor则通过工作窃取的方式，实现了线程间的任务负载均衡，每个工作线程通过主动调用smol::run加入工作环境。

       在Executor的实现中，ThreadLocalExecutor通过线程局部变量来管理任务的生命周期，确保了任务与线程的绑定。Blocking Executor通过自适应地开启线程，以应对任务的增加或减少，从而保持了系统的高效运行。Work Stealing Executor通过工作窃取的方式，实现了任务在多个线程间的合理分配，提高了系统的整体性能。

       每一个Executor的实现都紧密围绕着任务的调度、执行和管理，通过不同策略满足了不同场景下的需求。ThreadLocalExecutor适用于无法实现Send特性的Future，Blocking Executor能够应对阻塞任务的执行，而Work Stealing Executor则通过动态负载均衡实现了任务的高效分配。

       在使用smol异步运行时时，需要注意到几个关键点。async_std的运行时采用了延迟实例化、按需自动启动的策略，简化了使用体验。然而，smol目前采用的是手动启用运行时的策略，可能导致运行时panic问题，用户需要额外的配置来启动整个工作窃取运行环境。因此，正确配置和启动smol运行时对于开发者来说是源码如何阅读至关重要的。

       总结而言，smol的Executor组件设计精妙，通过不同类型的Executor满足了多样化的异步任务需求。其简洁而高效的设计，使得开发者能够轻松地将现有的库进行异步化处理，极大地提高了开发效率和系统性能。未来，随着smol的发展和完善，其在异步编程领域的应用将更加广泛。

async-validator源码解析（四）：Schema类

       深入async-validator源码解析，聚焦于Schema类核心

       在深入分析async-validator的校验库后，本次解析将自底向上探索最上层的Schema类，剖析其结构、属性及方法。通过github.com/MageeLin/asy... 的analysis分支，我们可以窥见每个文件的代码解析细节。

       解析依赖关系，了解Schema类与utils工具方法、messages.js默认消息间的相互作用。index.js文件中的Schema类及相关内容构成了async-validator的核心。

       Schema类是async-validator的标准接口，文档中示例步骤简洁明了：构造Schema实例、定义规则、验证数据。构造函数划分三步，关键在于原型链上的define方法，其代码较长，留待下篇深入探讨。

       在Schema构造函数及静态方法中，defaultMessages的引入凸显了针对不同失败校验提供定制提示消息的重要性。message模板适应不同项目的个性化需求，官方文档提供实例化Schema时添加message的示例。

       注意到默认的深度合并机制仅支持两级深合并，虽然这在当前情况下适用，但存在优化空间。回顾git记录，发现开发者改用手工实现的merge替代lodash的mergeWith，以减小包体积。

       控制台警告信息的显示可通过设置Schema实例前的warning方法实现屏蔽。源代码展示了warning方法的实现，仅在开发环境或非node运行时，使用console.warn打印errors数组中的错误。

       为了增强校验灵活性，官方提供了为自定义类型注册校验规则的静态方法register。在实例化前，通过调用Schema.register(type, validator)即可添加自定义类型的校验。

       综上所述，Schema类及其相关组件共同构成了async-validator的强大校验机制，通过深入理解其内部结构和工作流程，开发者能够更高效地利用该库实现数据验证功能。

Async、Await 从源码层面解析其工作原理

       深入理解 Async 和 Await 的工作原理，往往需要从源码层面进行剖析。使用 Babel 进行转换后，可以清晰地发现 Async 和 Await 实际上借助了 switch-case 和 promise，实现对流程的控制。以一个使用 Async 和 Await 的函数为例，我们仅关注核心部分代码。

       经过 Babel 转换后的 name 函数，可以被拆分为三个主要部分：await 部分、return 部分以及 async 流程控制的结束部分（即 case "end"）。这个拆分使得流程控制变得更为直观。在流程控制中，每一步执行后，都会等待合适的时机进入下一次执行。

       这个“合适的时机”并非由 Async 内部决定，而是由执行的内容决定。例如，在发送异步请求后，只有在请求返回后才会进入下一个 case。

       为了实现流程控制，需要借助 regenerator-runtime 这个 generator、Async 函数的运行时。它负责将 name 函数进行包装，并添加流程控制所需的信息。如 _context，以及用于流程控制的关键 helper，如 _asyncToGenerator 和 asyncGeneratorStep。通过这些辅助工具，再在 regenerator-runtime 的基础上进行一层包装，最终得到一个可以执行的函数。这个函数实际执行时，会调用封装后的函数。

       在封装后的函数中，async1、async2 等实际上是在执行最终的封装函数内部的调用。这里的第三步是 Async 函数的核心机制。在 Promise.resolve(value).then(_next) 中，value 是每个分段最后的 case 返回的值。如果 value 是一个 Promise，那么在它 resolved 后，会将其.then添加到微任务队列。如果 value 不是一个 Promise，则直接添加，因为.then是一个微任务，当执行到它时，会调用_next，从而开始执行下一个 case。

       经过转换后的代码展示了封装后的函数内容，最终执行的是封装后的函数，因此说 async1、async2 执行实际上是执行封装后的函数。在封装后的函数内部，会调用 async1、async2。

Vue3源码系列 (九)：异步组件 defineAsyncComponent 与 Suspense

       本文主要探讨Vue3源码中的异步组件API，包括defineAsyncComponent与。

       defineAsyncComponent用于定义异步组件，接受一个异步函数loader或一个包含loader的对象options作为参数。当使用options时，可以自定义更多细节，如加载延迟、异常处理、备选组件和加载中渲染等。通过使用import()动态加载，loader常用来结合它引入单文件组件以构成异步组件。在函数内部，定义了一个load函数，它处理loader的异常，并验证加载成功的结果。返回值为一个经过defineComponent处理过的options对象，其中setup包含异步组件的渲染逻辑。

       在定义异步组件后，createInnerComp在加载成功时根据得到的resolvedComp创建内部组件，实际上通过createVNode来实现渲染，并继承外部组件的ref。

       Suspense在Vue3.2中引入，提供类似组件的API，用于处理异步组件的渲染和错误场景。当组件检测到__isSuspense为真时，调用process方法在渲染器内部渲染组件。根据旧节点状态，process选择挂载或更新节点。

       mountSuspense用于首次加载异步组件的挂载逻辑，而patchSuspense负责新旧节点的对比和更新。Suspense包含多个分支，如活跃、等待、降级等状态，同时考虑异步依赖和降级状态。通过setActiveBranch设置活跃分支。

       SuspenseBoundary生成了一个Suspense实例，具备resolve、fallback、move、next、registerDep、unmount等方法。每个方法分别实现了解决异步结果、挂载降级内容、处理活跃分支和容器、递归取到活跃分支末端、注册依赖以及卸载SUSPENSE等核心功能。

       通过这些API的组合使用，Vue3实现了高效、灵活的异步组件加载机制，确保应用在处理复杂异步数据时依然保持流畅和响应性。

python协程（4）：asyncio

        asyncio是官方提供的协程的类库，从python3.4开始支持该模块

        async & awiat是python3.5中引入的关键字，使用async关键字可以将一个函数定义为协程函数，使用awiat关键字可以在遇到IO的时候挂起当前协程（也就是任务），去执行其他协程。

        await + 可等待的对象（协程对象、Future对象、Task对象 -> IO等待）

        注意：在python3.4中是通过asyncio装饰器定义协程，在python3.8中已经移除了asyncio装饰器。

        事件循环，可以把他当做是一个while循环，这个while循环在周期性的运行并执行一些协程（任务），在特定条件下终止循环。

        loop = asyncio.get_event_loop()：生成一个事件循环

        loop.run_until_complete(任务)：将任务放到事件循环

        Tasks用于并发调度协程，通过asyncio.create_task(协程对象)的方式创建Task对象，这样可以让协程加入事件循环中等待被调度执行。除了使用 asyncio.create_task() 函数以外，还可以用低层级的 loop.create_task() 或 ensure_future() 函数。不建议手动实例化 Task 对象。

        本质上是将协程对象封装成task对象，并将协程立即加入事件循环，同时追踪协程的状态。

        注意：asyncio.create_task() 函数在 Python 3.7 中被加入。在 Python 3.7 之前，可以改用 asyncio.ensure_future() 函数。

        下面结合async & awiat、事件循环和Task看一个示例

        示例一：

        *注意：python 3.7以后增加了asyncio.run（协程对象），效果等同于loop = asyncio.get_event_loop()，loop.run_until_complete(协程对象)

*

        示例二：

        注意：asyncio.wait 源码内部会对列表中的每个协程执行ensure_future从而封装为Task对象，所以在和wait配合使用时task_list的值为[func(),func()] 也是可以的。

        示例三：

async-validator源码解析（二）：rule

       async-validator源码解析（二）深入探讨rule模块，解析其内部的校验逻辑和依赖工具函数。本文将逐步揭开rule目录的面纱，以及util.js中关键的format和isEmptyValue方法。

       rule目录的核心是export的一系列校验方法，它们接受value、source、errors和options作为参数。value是当前字段的值，source是整个待校验的对象，而errors数组用于存储验证结果。options允许自定义验证消息。每种规则方法如required、whitespace、range等，都有特定的验证功能，例如检查必填性、空白字符、数值范围等。

       format函数是个灵活的工具，根据传入参数的不同执行不同的格式化操作。而isEmptyValue则用于判断值是否为空，包括空字符串和空数组。

       在rule目录中，type.js规则尤其有趣，通过组合简单的判断，区分了值的多种类型，如整数、浮点数、数组等。

       后续文章将继续关注validator目录，完整揭示async-validator校验库的运作机制。点击github.com/MageeLin/asy.../analysis分支，探索每个文件的详细代码解析。

Spring的@EnableAsync与@Async使用详解

       @EnableAsync注解允许Spring启动异步方法执行，类似于XML配置方式。当与@Configuration结合使用时，整个Spring环境将启用基于注解的异步处理。

       异步方法执行默认使用关联的线程池。若无匹配bean，Spring将使用SimpleAsyncTaskExecutor，它为每个新任务创建新线程。若异步方法返回值为void，调用过程中的异常信息无法返回给调用者，通常仅记录日志。

       自定义线程池和异常处理需实现AsyncConfigurer接口。若仅自定义一个，另一个可直接返回null，Spring将使用默认设置。使用AsyncConfigurerSupport扩展接口，可以全面配置。注意，当ThreadPoolTaskExecutor未被Spring管理时，可添加@Bean注解使其成为管理Bean。加入容器后，无需手动调用initialize方法，它在Bean初始化时自动执行。

       XML配置与基于javaconfig的示例功能等效，除了给Executor添加线程名字前缀。javaconfig方式提供更全面的配置。@EnableAsync注解的mode()属性控制切面应用：默认AdviceMode.PROXY，其他属性共同控制代理方式；若设置AdviceMode.ASPECTJ，则proxyTargetClass属性被忽略，此时需要spring-aspects相关模块的jar包，并且方法内部调用也会被拦截。

       @Async标注用于标记异步执行的方法，可加在方法或类上。加在类上表示类中所有方法均为异步执行。目标方法参数任意，返回值只能为void或Future，可以是ListenableFuture或CompletableFuture，以便更好地与异步任务交互。非future类型的返回值无法获取。

       探究EnableAsync源码，了解其内部工作流程。关注ProxyAsyncConfiguration配置类，它在PROXY模式下由Spring注入。分析AsyncAnnotationBeanPostProcessor，了解Executor和ExceptionHandler的配置过程。异步方法执行通过AnnotationAsyncExecutionInterceptor拦截器实现，最终在AsyncExecutionAspectSupport类中确定使用的Executor。

       详细实现步骤和测试代码可在GitHub上的相应仓库中找到。欢迎扫码关注以获取更多资源和信息。