test the shared_ptr async destruction (#58)

Author: mmomtchev

test/single.js

@@ -1,3 +1,5 @@
+#!/usr/bin/env node
+
 const fs = require('fs');
 const path = require('path');
 const framework = require('./framework');

test/tests/stress.cc

@@ -50,6 +50,10 @@ std::vector<Hello *> take_and_return_ptr_vector(const std::vector<Hello *> &inpu
 std::shared_ptr<Hello> take_and_return_shared_ptr(const std::shared_ptr<Hello> in) { return in; }
 std::shared_ptr<Hello> make_shared_ptr(std::string name) { return std::make_shared<Hello>(name); }
 
+std::string take_shared_ptr(std::shared_ptr<Hello> in) {
+  return in->Greet("Citizen");
+}
+
 NOBIND_MODULE(stress, m) {
   m.def<Hello>("Hello")
       .cons<std::string &>()
@@ -78,4 +82,5 @@ NOBIND_MODULE(stress, m) {
 
   m.def<&take_and_return_shared_ptr, Nobind::ReturnAsync>("take_and_return_shared_ptr");
   m.def<&make_shared_ptr, Nobind::ReturnAsync>("make_shared_ptr");
+  m.def<&take_shared_ptr, Nobind::ReturnAsync>("take_shared_ptr");
 }

test/tests/stress.js

@@ -126,6 +126,7 @@ describe('stress tests', function () {
       hellos[pick] = await dll.take_and_return_shared_ptr(hello);
     }
   });
+
   it('shared_ptr (start with a shared pointer)', async () => {
     // In this case JavaScript will always hold smart pointers
     const hellos = await Promise.all((new Array(1000)).fill(dll.make_shared_ptr('Merkwürdigliebe'), 0, 1000));
@@ -138,4 +139,23 @@ describe('stress tests', function () {
       hellos[pick] = await dll.take_and_return_shared_ptr(hello);
     }
   });
+
+  it('test shared_ptr destruction in background threads', async () => {
+    // https://github.com/mmomtchev/nobind/issues/56
+    // Make nobind create shared pointers out of anonymous
+    // JS objects and process them asynchronously to ensure
+    // that the JS reference is never released in a background
+    // thread
+    const q = [];
+    for (let i = 0; i < 5e4; i++) {
+      const pick = Math.floor(Math.random() * 1000);
+      q.push(dll.take_shared_ptr(new dll.Hello('Rasczak')));
+    }
+
+    const r = await Promise.all(q);
+    assert.lengthOf(r, 5e4);
+    for (const s of r) {
+      assert.strictEqual(s, 'hello Citizen Rasczak');
+    }
+  });
 });