【Mirror Networking】网络框架源码学习
在游戏开发领域，框架框架特别是源码源码用多人在线游戏的制作，网络框架的同步同步选择与理解至关重要。本文将带领大家了解并学习Mirror网络框架，框架框架这是源码源码用drivermonitor源码UNET的替代品，帮助开发者更好地掌握Unity项目内容。同步同步Mirror提供了强大的框架框架网络功能，使得客户端和服务端逻辑集成在同一个系统中。源码源码用
对于Mirror框架，同步同步CMD（Command）和RPC（Remote Procedure Call）是框架框架核心功能。CMD允许开发者在客户端和服务端之间传递命令，源码源码用而RPC则允许远程调用服务端方法，同步同步实现异步通信。框架框架这些标签用于区分客户端与服务端的源码源码用代码逻辑。
例如在Examples/Chat中，通过设置一个端作为服务器，其他端连接到localhost作为客户端，可以实现基本的聊天功能。值得注意的是，这个案例中的数据同步机制，尤其是SyncVar的作用，对于理解如何在客户端和服务端之间共享和同步数据至关重要。
SyncVar通过编译后处理和Update驱动同步实现数据的实时同步。在编译后处理阶段，通过SerializeSyncVars初始化所有SyncVar，并在逐帧更新中驱动同步过程，确保数据在客户端和服务端保持一致。
在服务器监听部分，以KcpTransport为例，分为初始化绑定、接收更新数据和业务处理。这一流程展示了如何在服务器端接收和处理网络数据，确保游戏逻辑的正确执行。
为了进一步深入学习，推荐查阅以下资源：
- Unity3D-network网络相关（一）_alayeshi的专栏-CSDN博客
- Unity3D-network网络相关（二）_alayeshi的专栏-CSDN博客
- 交大计算机课程（5）：计算机网络
- GitHub - vis2k/Mirror: #1 Open Source Unity Networking Library
- Mirror Documentation
- Unity 使用Mirror框架制作多人游戏
- MirrorNetworking
通过这些资源，开发者可以全面了解Mirror网络框架的使用方法，从而在多人游戏开发中获得更多的灵活性和控制力。
ONNX-Runtime一本通：综述&使用&源码分析（持续更新）
ONNX-Runtime详解：架构概览、实践与源码解析
ONNX-Runtime作为异构模型运行框架，其核心机制是先对原始ONNX模型进行硬件无关的图优化，之后根据支持的硬件选择相应的算子库，将模型分解为子模型并发在各个平台执行。它提供同步模式的计算支持，暂不包括异步模式。ORT（onnx-runtime缩写）是主要组件，包含了图优化（graph transformer）、执行提供者（EP）等关键模块。
EP是执行提供者，它封装了硬件特有的内存管理和算子库，可能只支持部分ONNX算子，但ORT的ext输出html源码CPU默认支持所有。ORT统一定义了tensor，但EP可有自定义，需提供转换接口。每个推理会话的run接口支持多线程，要求kernel的compute函数是并发友好的。
ORT具有后向兼容性，能运行旧版本ONNX模型，并支持跨平台运行，包括Windows、Linux、macOS、iOS和Android。安装和性能优化是实际应用中的重要步骤。
源码分析深入到ORT的核心模块，如框架（内存管理、tensor定义等）、图结构（构建、排序与修改）、优化器（包括RewriteRule和GraphTransformer），以及平台相关的功能如线程管理、文件操作等。Session是推理流程的管理核心，构造函数初始化模型和线程池，load负责模型反序列化，initialize则进行图优化和准备工作。
ORT中的执行提供者（EP）包括自定义实现和第三方库支持，如TensorRT、CoreML和SNPE。其中，ORT与CoreML和TensorRT的集成通过在线编译，将ONNX模型传递给这些框架进行计算。ORT通过统一的接口管理元框架之上的算子库，但是否支持异构运算（如SNPE与CPU库的混合）仍有待探讨。
总结来说，ONNX-Runtime处理多种模型格式，包括原始ONNX和优化过的ORT模型，以适应多平台和多设备需求。它通过复杂的架构和优化技术，构建了可扩展且高效的推理软件栈，展示了flatbuffer在性能和体积方面的优势。
附录：深入探讨ORT源码编译过程的细节。
硬核干货：4W字从源码上分析JUC线程池ThreadPoolExecutor的实现原理
深入剖析JUC线程池ThreadPoolExecutor的执行核心 早有计划详尽解读ThreadPoolExecutor的源码，因事务繁忙未能及时整理。在之前的文章中，我们曾提及Doug Lea设计的Executor接口，其顶层方法execute()是线程池扩展的基础。本文将重点关注ThreadPoolExecutor#execute()的实现，结合简化示例，逐步解析。 ThreadPoolExecutor的核心功能包括固定的核心线程、额外的正版授权源码下载非核心线程、任务队列和拒绝策略。它的设计巧妙地运用了JUC同步器框架AbstractQueuedSynchronizer(AQS)，以及位操作和CAS技术。以核心线程为例，设计上允许它们在任务队列满时阻塞，或者在超时后轮询，而非核心线程则在必要时创建。 创建ThreadPoolExecutor时，我们需要指定核心线程数、最大线程数、任务队列类型等。当核心线程和任务队列满载时，会尝试添加额外线程处理新任务。线程池的状态控制至关重要，通过整型变量ctl进行管理和状态转换，如RUNNING、SHUTDOWN、STOP等，状态控制机制包括工作线程上限数量的位操作。 接下来，我们深入剖析execute()方法。首先，方法会检查线程池状态和工作线程数量，确保在需要时添加新线程。这里涉及一个疑惑：为何需要二次检查？这主要是为了处理任务队列变化和线程池状态切换。任务提交流程中，addWorker()方法负责创建工作线程，其内部逻辑复杂，包含线程中断和适配器Worker的创建。 Worker内部类是线程池核心，它继承自AQS，实现Runnable接口。Worker的构造和run()方法共同确保任务的执行，同时处理线程中断和生命周期的终结。getTask()方法是工作线程获取任务的关键，它会检查任务队列状态和线程池大小，确保资源的有效利用。 线程池关闭操作通过shutdown()、shutdownNow()和awaitTermination()方法实现，它们涉及线程中断、任务队列清理和状态更新等步骤，以确保线程池的有序退出。在这些方法中，可重入锁mainLock和条件变量termination起到了关键作用，保证了线程安全。 ThreadPoolExecutor还提供了钩子方法，允许开发者在特定时刻执行自定义操作。除此之外，它还包含了监控统计、任务队列操作等实用功能，每个功能的MC源码官方要求实现都是对execute()核心逻辑的扩展和优化。 总的来说，ThreadPoolExecutor的execute()方法是整个线程池的核心，它的实现原理复杂而精细。后续将陆续分析ExecutorService和ScheduledThreadPoolExecutor的源码，深入探讨线程池的扩展和调度机制。敬请关注，期待下文的详细解析。WSL2 安装并下载、编译AOSP源码
安装WSL2
参考链接：安装WSL要求Windows 版本及更高版本（内部版本及更高版本）或Windows 。在power shell或cmd执行如下命令。
执行完之后就安装了Linux for Windows，并且打开了Windows的虚拟机平台和Linux子系统功能，并设置wsl默认版本为2。也可以手动安装，先在控制面板中找到启用或关闭Windows功能，勾选虚拟机平台和适用于Linux的Windows子系统功能。然后在应用商店找到Linux子系统（例如Ubuntu）进行安装。
如果是升级安装wsl，可能还需要同时升级linux内核。直接下载msi升级安装文件，点击安装即可。具体可参考：旧版WSL的手动安装步骤
硬盘设置
这里分为两类，一是将AOSP源码放在Windows文件系统下，二是将源码放置在WSL中。对于前者，需要修改文件目录的大小写敏感，新建完源码目录后，用管理员身份打开Windows的Powershell，执行以下命令：
其中的path就是刚新建用来同步AOSP源码的目录，需要注意的是，这个命令只对指定的目录有效，不会改变已存在的子目录的大小写敏感，所以要在同步代码之前设置好。根据文章：WSL编译AOSP必要的几个前置工作，还需要重新挂载磁盘。如果源码放在了Windows驱动器上，比如说F:\aosp，在WSL中的路径应该是/mnt/f/aosp这种形式的，此时需要以drvfs文件系统重新挂载盘符，否则编译到中途会报错：
注意，每次WSL重启，在编译之前都需要执行这步操作，也可以将它新建成WSL的一个开机服务，确保每次打开WSL都会执行这两段命令。如果是将源码放置在WSL中，需要注意WSL默认占用C盘空间，保证C盘有足够的空间，或者将WSL迁移到别的盘符。因为我的硬盘没有分区，不用担心占满C盘的空间，所以直接将源码放在WSL中编译。有序表查找源码WSL安装之后默认是GB大小，对于AOSP的编译是不够的。可通过df命令查看容量，下面是我编译完之后的容量，可以看到占用了GB。
扩展WSL 2虚拟硬盘的大小 如何管理WSL磁盘空间
输出如下：
经过如上操作，将wsl的虚拟磁盘大小调整到1TB。
源码下载
创建bin，并加入path：
下载repo：
下载代码有两种方式，使用每月更新的初始化包或者传统初始化方式。
下载mirrors.tuna.tsinghua.edu.cn...，下载完成后记得根据checksum.txt的内容校验一下。由于所有代码都是从隐藏的.repo目录中checkout出来的，所以我们只保留了.repo目录，下载后解压再repo sync一遍即可得到完整的目录。使用方法如下:
此后，每次只需运行repo sync即可保持同步。
建立工作目录并初始化仓库: repo init -u mirrors.tuna.tsinghua.edu.cn... 如果需要某个特定的Android版本(列表)： repo init -u mirrors.tuna.tsinghua.edu.cn... -b android-4.0.1_r1 同步源码树（以后只需执行这条命令来同步）： repo sync 详细可见：AOSP | 镜像站使用帮助 | 清华大学开源软件镜像站 | Tsinghua Open Source Mirror Android源码(AOSP)下载与编译 - 掘金
设置WSL内存大小
直接编译源码，会因为内存不足导致失败，通过free -m查看内存，只有4GB内存，swap空间只有2GB。可以通过设置WSL配置文件来修改相关配置属性。在用户目录下新建.wslconfig文件，在文件管理器输入%USERPROFILE%可找到用户文件夹。注意这里新建.wslconfig文件不要用新建文本文件的方式，这样文件可能没法被正确识别。可以通过命令行输入code .wslconfig的方式。
配置文件如下，根据自己的硬件配置尽可能多的分配多点资源，在编译完成后也能修改回来。我电脑是GB内存，所以给WSL配置GB内存，还有GB swap空间。
编译源码
编译源码就是常规流程，lunch项根据自己需要进行选择，编译线程数根据机器配置选择。
编译可能会报错缺少库文件，直接安装即可。sudo apt-get install libncurses5 如果需要编译出CMakeLists文件，方便导入CLion，需要在编译前添加环境变量。
编译成功！！
导入Clion效果。
若需要导入Android Studio中，还需要生成配置索引。
这一步需要Java环境，提前安装一下。sudo apt install openjdk--jdk
最终效果如下：
后端面经-JavaAQS详解
AQS是什么？
AQS定义了一套多线程访问共享资源的同步器框架，许多同步类实现都依赖于它，如常用的ReentrantLock。简单来说，AQS定义了一套框架，来实现同步类。
AQS的核心思想是对于共享资源，维护一个双端队列来管理线程，队列中的线程依次获取资源，获取不到的线程进入队列等待，直到资源释放，队列中的线程依次获取资源。AQS的基本框架如图所示：
资源state变量表示共享资源，通常是int类型。CLH双向队列是一种基于逻辑队列非线程饥饿的自旋公平锁，具体介绍可参考此篇博客。CLH中每个节点都表示一个线程，处于头部的节点获取资源，而其他资源则等待。Node的方法和属性值如图所示：其中,
一般来说，一个同步器是资源独占模式或者资源共享模式的其中之一，因此tryAcquire(int)和tryAcquireShared(int)只需要实现一个即可，tryRelease(int)和tryReleaseShared(int)同理。但是同步器也可以实现两种模式的资源获取和释放，从而实现独占和共享两种模式。
acquire(int)是获取资源的顶层入口，tryAcquire(int)是获取资源的方法，需要自定义同步器实现。addWaiter(Node.EXCLUSIVE)是将线程加入等待队列的尾部，acquireQueued(Node node, int arg)将线程阻塞在等待队列中，直到获取到资源后才返回。
release(int)是释放资源的顶层入口方法，tryRelease(int)是释放资源的方法，需要自定义同步器自己实现。unparkSuccessor(h)是唤醒后继节点的方法。
acquireShared(int)和releaseShared(int)是使用共享模式获取共享资源的顶层入口方法，tryAcquireShared(arg)是获取共享资源的方法，doAcquireShared(arg)将线程阻塞在等待队列中，直到获取到资源后才返回。releaseShared(int)是释放共享资源的顶层入口方法，doReleaseShared()方法释放共享资源。
面试问题模拟：AQS是接口吗？有哪些没有实现的方法？看过相关源码吗？
A：AQS定义了一个实现同步类的框架，实现方法主要有tryAquire和tryRelease，表示独占模式的资源获取和释放，tryAquireShared和tryReleaseShared表示共享模式的资源获取和释放。源码分析如上文所述。
ReentrantLock源码详细解析
在深入解析ReentrantLock源码之前，我们先了解ReentrantLock与同步机制的关系。ReentrantLock作为Java中引入的并发工具类，由Doug Lea编写，相较于synchronized关键字，它提供了更为灵活的锁管理策略，支持公平与非公平锁两种模式。AQS（AbstractQueuedSynchronizer）作为实现锁和同步器的核心框架，由AQS类的独占线程、同步状态state、FIFO等待队列和UnSafe对象组成。AQS类的内部结构图显示了其组件的构成。在AQS框架下，等待队列采用双向链表实现，头结点存在但无线程，T1和T2节点中的线程可能在自旋获取锁后进入阻塞状态。
Node节点作为等待队列的基本单元，分为共享模式和独占模式，值得关注的是waitStatus成员变量，它包含五种状态：-3、-2、-1、0、1。本文重点讨论-1、0、1状态，-3状态将不涉及。非公平锁与公平锁的差异在于，非公平锁模式下新线程可直接尝试获取锁，而公平锁模式下新线程需排队等待。
ReentrantLock内部采用非公平同步器作为其同步器实现，构造函数中根据需要选择非公平同步器或公平同步器。ReentrantLock默认采用非公平锁策略。非公平锁与公平锁的区别在于获取锁的顺序，非公平锁允许新线程跳过等待队列，而公平锁严格遵循队列顺序。
在非公平同步器的实例中，我们以T1线程首次获取锁为例。T1成功获取锁后，将exclusiveOwnerThread设置为自身，state设置为1。紧接着，T2线程尝试获取锁，但由于state为1，获取失败。调用acquire方法尝试获得锁，尝试通过tryAcquire方法实现，非公平同步器的实现调用具体逻辑。
在非公平锁获取逻辑中，通过CAS操作尝试交换状态。交换成功后，设置独占线程。当当前线程为自身时，执行重入操作，叠加state状态。若获取锁失败，则T2和T3线程进入等待队列，调用addWaiter方法。队列初始化通过enq方法实现，enq方法中的循环逻辑确保线程被正确加入队尾。新线程T3调用addWaiter方法入队，队列初始化完成。
在此过程中，T2和T3线程开始自旋尝试获取锁。若失败，则调用parkAndCheckInterrupt()方法进入阻塞状态。在shouldParkAfterFailedAcquire方法中，当前驱节点等待状态为CANCELLED时，方法会找到第一个非取消状态的节点，并断开取消状态的前驱节点与该节点的连接。若T5线程加入等待队列，T3和T4线程因为自旋获取锁失败进入finally块调用取消方法，找到等待状态不为1的节点（即T2），断开连接。
理解了shouldParkAfterFailedAcquire方法后，我们关注acquireQueued方法的实现。该方法确保线程在队列中正确释放，如果队列的节点前驱为head节点，成功获取锁后，调用setHead方法释放线程。setHead方法通过CAS操作更新head节点，释放线程。acquire方法中的阻塞是为防止线程在唤醒后重新尝试获取锁而进行的额外阻断。
锁的释放过程相对简单，将state减至0，将exclusiveOwnerThread设置为null，完成锁的释放。通过上述解析，我们深入理解了ReentrantLock的锁获取、等待、释放等核心机制，为并发编程提供了强大的工具支持。
Github上Fork开源代码，本地二次开发，保持源码同步
在Github上，获取并利用开源代码进行本地二次开发是一项常见操作。首先，你需要通过Fork功能复制一个大佬的开源代码仓库，这就像克隆一个项目，让你可以在不影响原始项目的情况下进行试验或贡献代码。要实现这一点，只需简单地执行两个步骤：
1. Fork仓库：复制链接后，使用git clone命令，将仓库克隆到本地，例如：`git clone /YOUR-USERNAME/origin-repo.git`
2. 同步本地副本：为保持与原始仓库同步，你需要配置git。通常，这涉及设置upstream指向主仓库，然后使用git pull从upstream获取更新。如果你想将这些更改推送到你的Fork仓库，还需要执行一次`git push`操作。
通过这些步骤，你就可以在本地对Fork的源代码进行修改，并确保与原始代码库保持同步。这是开源社区中协作开发的基础实践，帮助开发者们扩展和改进现有的开源项目。
AbstractQueuedSynchronizer详解
AbstractQueuedSynchronizer，简称AQS，究竟是什么呢？
它提供了一个框架，用于实现基于先进先出（FIFO）等待队列的阻塞锁及相关同步器（如信号量、事件等）。这个类的设计目的是为了成为那些依赖单一原子整数值来表示状态的同步器的有效基础。
从JDK的注释来看，AQS是一个实现阻塞锁和相关同步器的框架，它基于先进先出的等待队列。这个类适用于大多数使用整数来表示状态的同步器。这里提到的框架实际上是一个类。
那么，在什么情况下我们会使用AQS呢？
在编程中，我们经常遇到并发问题。有了并发，就涉及资源共享；而资源共享又需要处理资源的同步访问。在处理同步时，我们需要解决竞争发生时的等待问题和竞争解除后的唤醒问题。AQS就是这样一个便于实现这种同步机制的框架。我们日常使用的ReentrantLock、ReentrantReadWriteLock以及ArrayBlockingQueue等都是基于AQS实现的。
如果没有AQS，又会如何呢？
在没有AQS的情况下，要实现锁需要怎么做呢？这些问题都是我们在实现锁时需要考虑的。
在AQS的情况下，情况又是怎样的呢？
AQS作为基础类，主要解决了在锁不可用时的等待，以及锁释放后的唤醒。锁状态的设定、如何获取锁以及如何释放锁，都是需要相应的同步机制自己实现的。因此，在使用AQS时，需要实现以下方法：
类似于ReentrantLock，使用state来标识锁的状态，state = 0表示锁未被获取，当state > 0表示锁已被获取。此外，实现了AQS的tryAcquire()和tryRelease()来处理state的状态，以处理锁的状态。这样就可以实现基础的ReentrantLock。因此，在AQS的支持下，实现类似的阻塞锁非常方便。
以上我们介绍了AQS是什么，以及AQS的具体使用场景，下面我们详细介绍AQS的具体实现机制。
我们先简单看一下AQS的核心流程。
接下来，我们将结合ReentrantLock来详细查看基于AQS如何实现排他锁。
首先，我们来看一下ReentrantLock是如何使用int类型的state来表示锁的状态的。state = 0表示锁未被获取。state > 0表示锁已被持有。由于是可重入锁，state表示了这个锁被同一个线程获取了多少次。
上面的代码片段是ReentrantLock的核心代码，为了便于解释，省略了其他代码。首先我们可以看到，在使用AQS时，通常不是直接实现AQS，而是创建一个内部的辅助类。
Subclasses should be defined as non-public internal helper classes that are used to implement the synchronization properties of their enclosing class
然后加锁和释放锁对应的lock和unlock，直接调用辅助类的lock和unlock。
下面我们来看一下Sync类的代码。
上面我们来看一下非公平锁NonfairSync的实现。
下面我们来看一下AQS中的acquire方法。
上面我们看了获取锁的方法acquire，下面看下释放锁的release。
总结一下，AQS通过tryAcquire以及tryRelease两个方法，来进行锁的获取以及释放，两个都是非阻塞的方法。如果获取成功则返回，如果获取失败，则添加队列。在队列中获取锁，获取失败则挂起，等待锁被释放后被重新唤醒。唤醒后还是会去尝试获取锁。释放锁的时候如果检查到已经全部释放，则会唤醒被挂起的线程。这样通过tryAcquire和tryRelease，实现了锁的获取以及等待，以及锁的释放。具体锁状态的控制，子类则是通过tryAcquire和tryRelease进行控制的。
在介绍ReentrantLock时，我们简化了很多代码。了解基本原理后，再去读源码会事半功倍。
2024-11-29 23:52
2024-11-29 23:25
2024-11-29 22:20
2024-11-29 21:59
2024-11-29 21:24
