c++ - 正确处理 Persistent<ArrayBuffer>

Question

我得到了非常简单的代码:

struct Dyn {
 float *ptr;
 int n;
};


void setWeakFunction1(const WeakCallbackInfo<Dyn> &data) {
}
void setWeakFunction(const WeakCallbackInfo<Dyn> &data) {
 auto *v = data.GetParameter();
 data.SetSecondPassCallback(setWeakFunction1);
 std::cout << v->n << " Collector\n";
 delete[] v->ptr;
 delete v;

}

void getIndex(const FunctionCallbackInfo<Value> &args) {
  Dyn *d = new Dyn;
  float *ptr = new float[amount];
  for (size_t i = 0; i < amount; ++i) {
    ptr[i] = i + 2;
  }

  auto isolate = Isolate::GetCurrent();
  HandleScope scope(isolate);
  Local<ArrayBuffer> ab =
      ArrayBuffer::New(isolate, ptr, amount * sizeof(float));
  Persistent<ArrayBuffer> pab(isolate, ab);
  pab.SetWeak(d, setWeakFunction, WeakCallbackType::kInternalFields);
  pab.MarkIndependent();
  args.GetReturnValue().Set(ab);
}

void RegisterModule(Local<Object> exports, Local<Object>) {
 auto isolate = Isolate::GetCurrent();
 exports->Set(String::NewFromUtf8(isolate, "getIndex"),
           FunctionTemplate::New(isolate, getIndex)->GetFunction());
}

NODE_MODULE(commander, RegisterModule)

这段代码对我来说有些尴尬。

因为有一个计数器，我希望为我创建的每个 Persistence 存储调用 setWeakFunction。当 float 量小于 10000 时，它会调用每个 Persistent cell。但是当 float 的大小变为 100 000 时，它不会尝试处理任何对象，直到有 1Gb 的内存被吃掉，然后它不断删除，但留下 2-3 个对象。

我有一个想法，垃圾收集器为一堆对象调用一次 WeakCallback，但没有找到信息，证实了这一点。

更糟糕的是，我从未见过任何针对 1000 000 float 组的垃圾收集调用。

如何正确处理这个数组？

Answer 1

让我尝试修复上面的代码:

struct Dyn {
    Persistent<ArrayBuffer> pab;
    float *ptr;
    int n;
};

void setWeakFunction(const WeakCallbackInfo<Dyn> &data) {
    auto *v = data.GetParameter();
    std::cout << v->n << " Collector\n";
    v->pab.Reset();
    delete[] v->ptr;
    delete v;

}

void getIndex(const FunctionCallbackInfo<Value> &args) {
    Dyn *d = new Dyn;
    float *ptr = new float[amount];
    for (size_t i = 0; i < amount; ++i) {
        ptr[i] = i + 2;
    }

    auto isolate = args.GetIsolate();
    HandleScope scope(isolate);
    Local<ArrayBuffer> ab =
        ArrayBuffer::New(isolate, ptr, amount * sizeof(float), ArrayBufferCreationMode::kExternalized);
    d->pab.Reset(isolate, ab);
    d->pab.SetWeak(d, setWeakFunction, WeakCallbackType::kParameter);
    d->pab.MarkIndependent();
    args.GetReturnValue().Set(ab);
}

void RegisterModule(Local<Object> exports, Local<Object>) {
    auto isolate = Isolate::GetCurrent();
    exports->Set(String::NewFromUtf8(isolate, "getIndex"),
        FunctionTemplate::New(isolate, getIndex)->GetFunction());
}

NODE_MODULE(commander, RegisterModule)