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

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