examples/typescript/http-server-pool/fastify-worker_threads/src/main.ts

   1 import { dirname, extname, join } from 'node:path'
   2 import { exit } from 'node:process'
   3 import { fileURLToPath } from 'node:url'
   4
   5 import Fastify from 'fastify'
   6
   7 import { fastifyPoolifier } from './fastify-poolifier.js'
   8
   9 /**
  10  * The fastify server is still a single-threaded application, but the request handling can be multi-threaded.
  11  */
  12
  13 const port = 8080
  14 const fastify = Fastify({
  15   logger: true
  16 })
  17
  18 const workerFile = join(
  19   dirname(fileURLToPath(import.meta.url)),
  20   `worker${extname(fileURLToPath(import.meta.url))}`
  21 )
  22
  23 await fastify.register(fastifyPoolifier, {
  24   workerFile,
  25   enableTasksQueue: true,
  26   tasksQueueOptions: {
  27     concurrency: 8
  28   },
  29   errorHandler: (e: Error) => {
  30     fastify.log.error('Thread worker error:', e)
  31   }
  32 })
  33
  34 fastify.all('/api/echo', async request => {
  35   return (await fastify.execute({ body: request.body }, 'echo')).body
  36 })
  37
  38 fastify.get<{
  39   Params: { number: number }
  40 }>('/api/factorial/:number', async request => {
  41   const { number } = request.params
  42   return (await fastify.execute({ body: { number } }, 'factorial')).body
  43 })
  44
  45 try {
  46   await fastify.listen({ port })
  47 } catch (err) {
  48   fastify.log.error(err)
  49   exit(1)
  50 }