Part 2 - Worker Threads - Index.js

index.js

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

const http = require('http')
const { StaticPool } = require('node-worker-threads-pool')
const numCPUs = require('os').cpus().length

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

const host = '192.168.0.14'
const port = 8080

const start = function startServer() {
    // Path to worker.js
    const filePath = './worker.js'

    // Create worker pool
    const pool = new StaticPool({
        size: 16,
        task: filePath,
        workerData: {},
    })

    // Simple request router
    const router = async function requestRouter(request, reply) {
        // Send to workers
        try {
            await pool.exec()
        } catch (e) {
            console.log(e)
            process.exit(0)
        }
        // console.log(result)
        reply.end('OK')
    }

    // Start HTTP server
    const server = http.createServer(router)
    server.listen(port, host, () => {
        console.log(`Node.js Standard Library HTTP server running on port: ${port}`)
    })
}

start()