Node.js eval worker Segmentation fault reproduction

eval_cjs.mjs

import { Worker } from 'worker_threads'

function genWorkerCode(fn) {
  return `
const doWork = ${fn.toString()}
const { parentPort } = require('worker_threads')
parentPort.on('message', async (args) => {
  const res = await doWork(...args)
  parentPort.postMessage(res)
})
  `
}

// 10s after. 0-9s works well
const startAt = Date.now() + 10 * 1000

const fn = async (_startAt) => {
  const until = new Date(_startAt).valueOf() - Date.now()
  await new Promise((resolve) => setTimeout(resolve, until))

  import('worker_threads') // fails
  // require('worker_threads') // success
}
// same behavior when fn is string
/*
const fn = `async (_startAt) => {
  const until = new Date(_startAt).valueOf() - Date.now()
  await new Promise((resolve) => setTimeout(resolve, until))

  import('worker_threads') // fails
  // require('worker_threads') // success
}
`
*/

const code = genWorkerCode(fn)
const worker = new Worker(code, { eval: true })
worker.on('message', (res) => {
  console.log('done', res)
  worker.unref()
})
worker.on('error', (err) => {
  console.error('error', err)
  worker.unref()
})
worker.on('exit', (code) => {
  console.log('exit', code)
})
worker.postMessage([startAt])

eval_cjs_cjs.js

const { Worker } = require('worker_threads')

function genWorkerCode(fn) {
  return `
const doWork = ${fn.toString()}
const { parentPort } = require('worker_threads')
parentPort.on('message', async (args) => {
  const res = await doWork(...args)
  parentPort.postMessage(res)
})
  `
}

// 10s after. 0-9s works well
const startAt = Date.now() + 10 * 1000

const fn = async (_startAt) => {
  const until = new Date(_startAt).valueOf() - Date.now()
  await new Promise((resolve) => setTimeout(resolve, until))

  import('worker_threads') // fails
  // require('worker_threads') // success
}
// same behavior when fn is string
/*
const fn = `async (_startAt) => {
  const until = new Date(_startAt).valueOf() - Date.now()
  await new Promise((resolve) => setTimeout(resolve, until))

  import('worker_threads') // fails
  // require('worker_threads') // success
}
`
*/

const code = genWorkerCode(fn)
const worker = new Worker(code, { eval: true })
worker.on('message', (res) => {
  console.log('done', res)
  worker.unref()
})
worker.on('error', (err) => {
  console.error('error', err)
  worker.unref()
})
worker.on('exit', (code) => {
  console.log('exit', code)
})
worker.postMessage([startAt])

noneval_cjs.mjs

import { Worker } from 'worker_threads'

// 10s after.
const startAt = Date.now() + 10 * 1000

const worker = new Worker('./worker.js')
worker.on('message', (res) => {
  console.log('done', res)
  worker.unref()
})
worker.on('error', (err) => {
  console.error('error', err)
  worker.unref()
})
worker.on('exit', (code) => {
  console.log('exit', code)
})
worker.postMessage([startAt])

noneval_mjs.mjs

import { Worker } from 'worker_threads'

// 10s after.
const startAt = Date.now() + 10 * 1000

const worker = new Worker('./workerm.mjs')
worker.on('message', (res) => {
  console.log('done', res)
  worker.unref()
})
worker.on('error', (err) => {
  console.error('error', err)
  worker.unref()
})
worker.on('exit', (code) => {
  console.log('exit', code)
})
worker.postMessage([startAt])

package.json

{
  "name": "po",
  "version": "1.0.0",
  "description": "",
  "author": "sapphi-red"
}

worker.js

const doWork = async (_startAt) => {
  const until = new Date(_startAt).valueOf() - Date.now()
  await new Promise((resolve) => setTimeout(resolve, until))

  import('worker_threads') // success
  // require('worker_threads') // success
}
const { parentPort } = require('worker_threads')
parentPort.on('message', async (args) => {
  const res = await doWork(...args)
  parentPort.postMessage(res)
})

workerm.mjs

import { parentPort } from 'worker_threads'
const doWork = async (_startAt) => {
  const until = new Date(_startAt).valueOf() - Date.now()
  await new Promise((resolve) => setTimeout(resolve, until))

  import('worker_threads') // success
}
parentPort.on('message', async (args) => {
  const res = await doWork(...args)
  parentPort.postMessage(res)
})