Fix panic during shutdown when using channel

crates/neon/src/event/channel.rs

@@ -249,7 +249,9 @@ impl Drop for Channel {
         // UV thread if strong reference count goes to 0.
         let state = Arc::clone(&self.state);
 
-        self.send(move |mut cx| {
+        // Use `try_send` instead of `send` because, if `send` fails, it means we're shutting down
+        // the VM and don't need to worry about cleanup.
+        let _ = self.try_send(move |mut cx| {
             state.unref(&mut cx);
             Ok(())
         });

test/napi/lib/workers.js

@@ -4,6 +4,7 @@ const {
   isMainThread,
   parentPort,
   threadId,
+  workerData,
 } = require("worker_threads");
 
 const addon = require("..");
@@ -15,7 +16,11 @@ if (!isMainThread) {
   // succeed even if the presence of a bug.
   addon.reject_after(new Error("Oh, no!"), 200).catch(() => {});
 
+  // Reproduce another shutdown bug; this one isn't timing-dependent.
+  let boxed_channels = addon.box_channels();
+
   addon.get_or_init_thread_id(threadId);
+
   parentPort.once("message", (message) => {
     try {
       switch (message) {
@@ -44,6 +49,10 @@ if (!isMainThread) {
     }
   });
 
+  if (workerData === "notify_when_startup_complete") {
+    parentPort.postMessage("startup_complete");
+  }
+
   return;
 }
 
@@ -194,9 +203,13 @@ describe("Instance-local storage", () => {
   });
 
   it("should be able to exit a worker without a crash", (cb) => {
-    const worker = new Worker(__filename);
+    const worker = new Worker(__filename, {
+      workerData: "notify_when_startup_complete",
+    });
 
-    setTimeout(() => worker.terminate(), 50);
-    setTimeout(cb, 100);
+    worker.once("message", async () => {
+      await worker.terminate();
+      cb();
+    });
   });
 });

test/napi/src/js/workers.rs

@@ -108,3 +108,20 @@ pub fn reject_after(mut cx: FunctionContext) -> JsResult<JsPromise> {
 
     Ok(promise)
 }
+
+#[allow(dead_code)]
+pub struct Channels {
+    channel_1: Channel,
+    channel_2: Channel,
+}
+impl Finalize for Channels {}
+
+pub fn box_channels(mut cx: FunctionContext) -> JsResult<JsBox<Channels>> {
+    let channel_1 = cx.channel();
+    let channel_2 = cx.channel();
+
+    Ok(cx.boxed(Channels {
+        channel_1,
+        channel_2,
+    }))
+}

test/napi/src/lib.rs

@@ -384,6 +384,7 @@ fn main(mut cx: ModuleContext) -> NeonResult<()> {
     cx.export_function("stash_global_object", js::workers::stash_global_object)?;
     cx.export_function("unstash_global_object", js::workers::unstash_global_object)?;
     cx.export_function("reject_after", js::workers::reject_after)?;
+    cx.export_function("box_channels", js::workers::box_channels)?;
 
     // Futures
     cx.export_function("lazy_async_add", js::futures::lazy_async_add)?;