refactor: Vm 加 unsafe impl Send,移除 vm_pool 的 Send 抑制

This commit is contained in:
2026-10-07 01:50:02 +00:00
parent abe731a313
commit 55bec82f69
4 changed files with 52 additions and 25 deletions
+26
View File
@@ -392,6 +392,32 @@ impl Drop for Vm {
}
}
// SAFETY: Vm 可安全跨线程移动(Send),依据四条不变量:
//
// 1. session 堆随 Vm 整体迁移:Vm 内全部裸指针(session 对象表
// session_object_ptrs、字符串表 session_string_ptrs、BigInt/cell 表、
// upvalue cell 指针、active_immutables 视图、length_perm_ptr)指向的堆对象
// 均由该 Vm 独占分配(Box::into_raw 统一入口),地址稳定、不随 Vm 移动而
// 搬移。跨线程移动 Vm 时指针恒有效,不产生悬垂。
//
// 2. &Vm 不跨线程共享:Vm 只经 &mut Vm 在单线程内访问(池化 VmGuard 独占
// 借出),RefCell(GcState 的 BigInt/cell 表、Realm 的 session/gc/P 字段)
// 与 Cell(profiling 计数)的非 Sync 性不构成跨线程数据竞争。
//
// 3. GC 根集不跨线程共享:每个 Vm 持有独立的 session 堆、独立的 mark/sweep
// 表与水位,无跨 Vm 的 GC 边。KernelCore 经 Arc<KernelCore> 共享
// (Send + Sync),是唯一的跨 Vm 共享面,其内部为 append-only forge 与
// 原子计数,无 per-VM 可变状态。
//
// 4. 裸指针不跨线程逃逸:Vm 内的裸指针只指向本 Vm 的 session 堆或共享 kernel
// 对象(perm 串 / shape / code forge),不指向其他 Vm 的堆。跨线程移动
// Vm 时这些指针的指向不变(堆对象地址稳定),不引入别名。
//
// realm 字段为 Arc<Realm>:Realm 的 session 堆不跨线程共享,Arc 引用计数为
// 原子操作,跨线程移动 Arc 安全;Realm 只经 Vm(单线程 &mut)访问,
// 其非 Sync 性对 Send 无碍。
unsafe impl Send for Vm {}
impl Vm {
const SYNC_NATIVE_ARG_BASE: usize = 0;
const SYNC_NATIVE_ARG_LIMIT: usize = 253;
+7 -6
View File
@@ -1,5 +1,3 @@
#![allow(clippy::arc_with_non_send_sync)]
use std::sync::atomic::{AtomicUsize, Ordering};
use std::sync::{Arc, Condvar, Mutex};
use std::time::Duration;
@@ -15,8 +13,9 @@ struct VmPoolInner {
/// 池状态计数器:空闲数、在借数、峰值借出数与已创建总数的跨线程可读快照。
///
/// 池本体不是 Send/Sync(Vm 不跨线程),状态接口经独立原子暴露,
/// 与队列变更同步更新;空闲数恒不大于总数(总数只增不减)。
/// 池本体是 Send/Sync(Vm 经 unsafe impl Send 跨线程移动,VmGuard 独占借出
/// 不共享 &Vm),状态接口经独立原子暴露,与队列变更同步更新;
/// 空闲数恒不大于总数(总数只增不减)。
/// 安静态(无并发借出归还)下在借数恒等于总数减空闲数;峰值是每次
/// 借出后精确在借数的最大值,单调不降。
pub struct PoolCounters {
@@ -109,7 +108,8 @@ impl VmPool {
/// (共享聚合上不得覆盖写,各池各自累加)。
///
/// # 边界与前提
/// - 计数器通常经 `PoolCounters::shared` 跨线程共享;池本体不跨线程移动。
/// - 计数器通常经 `PoolCounters::shared` 跨线程共享;池本体可跨线程移动
/// (Send/Sync),worker 经 spawn 独占借出 Vm。
///
/// # 副作用
/// - 同步创建 `min_size` 个 Vm。
@@ -428,7 +428,8 @@ mod tests {
let kernel = Arc::clone(&kernel);
let counters = Arc::clone(&counters);
std::thread::spawn(move || {
// 池本体不跨线程(Vm 不 Send),每线程自建池、共享同一聚合计数器。
// 每线程自建池、共享同一聚合计数器(Vm 经 unsafe impl Send 可
// 跨线程,本测试仍按每线程自有池验证计数器聚合)。
let pool = VmPool::with_counters(kernel, 0, Some(8), counters);
for _ in 0..50 {
let guard = pool.spawn();