如何有效管理Node.js中ArrayBuffer的内存占用

async function processData() {
  const blob = new Blob(['This is a sample text for ArrayBuffer']);
  const buf = await blob.arrayBuffer(); // buf现在持有二进制数据
  console.log(`ArrayBuffer byteLength: ${buf.byteLength}`);

  // 此时，即使buf不再被显式使用，其内存可能不会立即释放
  // 假设这里不再需要buf
}

processData();

/**
 * 启动一个定时清理ArrayBuffer内存的机制。
 * 该机制会周期性检查ArrayBuffer的内存占用，
 * 如果超过预设阈值，则手动触发垃圾回收。
 */
const startArrayBufferCleanup = () => {
  const CLEANUP_THRESHOLD_KB = 5000; // 阈值：5MB
  let cleanUpTimer = null;

  // 确保在Node.js启动时添加 --expose-gc 参数
  if (typeof global.gc !== 'function') {
    console.warn('Warning: global.gc() is not exposed. Please run Node.js with --expose-gc flag.');
    return;
  }

  cleanUpTimer = setInterval(() => {
    // 获取当前进程的内存使用信息
    const memoryUsage = process.memoryUsage();
    // arrayBuffers字段表示ArrayBuffer对象占用的内存，单位为字节
    const arrayBuffersMemoryKB = Math.floor(memoryUsage.arrayBuffers / 1024);

    console.log(`[GC Monitor] Current ArrayBuffer memory: ${arrayBuffersMemoryKB} KB`);

    if (arrayBuffersMemoryKB > CLEANUP_THRESHOLD_KB) {
      console.log(`[GC Trigger] ArrayBuffer memory (${arrayBuffersMemoryKB} KB) exceeds threshold (${CLEANUP_THRESHOLD_KB} KB). Triggering GC...`);
      global.gc(); // 触发垃圾回收
      console.log('[GC Trigger] GC triggered.');
    } else {
      // 如果内存低于阈值，可以选择停止定时器，节省资源
      // 或者继续监控，这取决于具体的应用场景
      // console.log('[GC Monitor] ArrayBuffer memory is below threshold. Continuing monitoring.');
    }
  }, 5000); // 每5秒检查一次

  // 返回定时器ID，以便外部可以清除它
  return cleanUpTimer;
};

// 启动清理机制
const timerId = startArrayBufferCleanup();

// 示例：模拟ArrayBuffer的创建和释放
async function simulateArrayBufferUsage() {
  console.log('Simulating ArrayBuffer usage...');
  for (let i = 0; i < 10; i++) {
    const data = 'a'.repeat(1024 * 1024 * 0.6); // 每次创建约0.6MB的数据
    const encoder = new TextEncoder();
    const encodedData = encoder.encode(data);
    const largeBuffer = encodedData.buffer; // 创建一个ArrayBuffer
    console.log(`Created buffer of size: ${largeBuffer.byteLength / 1024} KB`);
    // 在这里，largeBuffer在循环迭代结束后会失去引用
    // 但其内存可能不会立即释放
    await new Promise(resolve => setTimeout(resolve, 100)); // 模拟异步操作
  }
  console.log('Finished simulating ArrayBuffer usage.');
}

// 运行模拟，观察GC监控器的输出
simulateArrayBufferUsage();

// 假设在某个时刻，你不再需要这个监控器了
// setTimeout(() => {
//   console.log('Stopping ArrayBuffer cleanup monitor.');
//   clearInterval(timerId);
// }, 60000); // 运行一分钟后停止

node --expose-gc your_script_name.js