worker.js

// ════════════════════════════════════════════════════════════════════════════════════════════════╡

const { parentPort, workerData } = require('worker_threads')
const crypto = require('crypto')
const util = require('util')
const fs = require('fs')

// ════════════════════════════════════════════════════════════════════════════════════════════════╡

const asyncFs = util.promisify(fs.readFile)

parentPort.on('message', async (times) => {
  if (typeof times !== 'number') {
    throw new Error('times must be a number.')
  }
  const result = await asyncFs('./data/test.dat', 'utf8')

  let resStr = ''
  for (let i = 0; i < times; i += 1) {
    const x = crypto.createHash('sha256')
    x.update(result, 'utf8')
    resStr = x.digest('hex')
  }
  // Access the workerData.
  // console.log('workerData is', workerData)

  // return the result to main thread.
  parentPort.postMessage(resStr)
})