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，源用它擅长处理有依赖关系的码使无盘驱动源码短任务；本篇教程我们将学习Thread，它与TaskGraph相反，源用它更擅长于处理长任务。码使而下一篇文章，源用我们则会承接Thread，码使去学习一下引擎中一些重要的源用线程。

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

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

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

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

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

       逻辑分为两部分：启动分线程计算数字和，使用Async函数，参数为EAsyncExecution::Thread，创建新线程执行。学习Async函数用法，该函数返回TFuture对象，代表未来状态，微信点单系统源码当前无法获取结果，但在未来某个时刻状态变为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。这些工具的引入，使得在多线程环境中访问异步操作的易语言批量加好友源码结果变得更加方便。

       传统上，在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源码的详细分析，可以参考我的视频教程，或者私聊我进行深入探讨。糗事百科app源码我的文章和视频内容涵盖了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运行时对于开发者来说是php微信分销系统源码至关重要的。

       总结而言，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上的相应仓库中找到。欢迎扫码关注以获取更多资源和信息。