node_shared_queue.js

function JavaToJSNotifier {
  this.queue = new java.util.concurrent.LinkedBlockingDeque();
  this.worker = new Worker(`
      const { workerData, parentPort } = require('worker_threads');
      while (true) {
        // block the worker waiting for the next notification from Java
        var data = workerData.queue.take();
        // notify the main event loop that we got new data 
        parentPort.postMessage(data);
      }`,
      {eval: true, workerData: { queue: this.queue }});
}

// register a callback to be executed when something is added to the shared queue
const asyncJavaEvents = new JavaToJSNotifier();
asyncJavaEvents.worker.on('message', (n) => {
  console.log(`Got new data from Java! ${n}`);
});

// pass the queue to Java, to give a way to notify us back when data is available
const MyJavaClass = Java.type('my.java.AwesomeClass');
new MyJavaClass(asyncJavaEvents.queue).start();