NODEJS and something cool
1. Thread pool size
Test asynchronous in Nodejs (ThreadPool explaination)
- Source code:
thread-pool.js - By default, threadpool size of Nodejs is 4. So, in this example we will see when running the code, only 4 function complete at a time.
- But when you change the default size by the command
process.env.UV_THREADPOOL_SIZE = 5
- Now, you run the code and see the result. Amazing, all of request http commands finish first and after that hash commands also complete (the order is 1-2-3-4-5-6-7-8-9-10-11-12-13) -> Changing thread pool size to 5 makes your Node process can run with 5 threads at a time.
- The next question is:
Why all request http complete before hash with 5 threads? See the next section.
2. Nodejs IO
- Here we see all request commands finish first, and then all hash commands complete.
- So why???
- First you need to know how request http in Nodejs work:
- When you call a request to network io in Nodejs, under the hood it make a call to low level to create a socket which is built-in to serve network io. Here, Nodejs use epoll or kqueue rely on Unix distribution (bring non-blocking network io).
- Epoll help us not block the thread until data is readable (request completes). It has 2 phases:
- Phase 1: Create a poll to get status of file descriptor (request status)
- Phase 2: If data is readable -> execute read data (blocking operation), otherwise return Phase 1.
- Similar, File system io has two phase, first to get file descriptor (file stat) and then read the content of file.
- Return this situation, we can now explain what happens:
- We has 5 threads in pool, first we run 1-2-3-4-5
- With threads 1 -> 4, the hash command compute on cpu, suppose it takes ~500ms.
- With thread 5, it makes a request and then poll to get file descriptors, now the request is incomplete so this thread is available to use.
- And now in thread pool remain one thread and other request commands continues polling then detach.
- When all of requests are made and system now are polling to see if response is readable.
- And a request take ~200ms, so after 200ms we can read data response one by one, and because reading data response takes very little time so you will see all requests complete at a glance.
- If you increase time in setTimeout in
server.js, you can see some hash commands finish first.
- That all, you can now change the order of command and see what effects. Happy coding!
3. Macro tasks and micro tasks
- Macro tasks includes: setTimeout, event, ... can think these like phases in event loop
- Micro tasks includes promises in your code, all micro task will be executed before another macro task takes place -> so no event or network data between microtasks.
4. Nodejs streams
-
How stream work?
-
References:
-
[Wiki] Stream is a sequence of data elements made available over time. A stream can be thought of as items on a conveyor belt being processed one at a time rather than in large batches.
-
Flow:
________ ______ ________ |Provider| ->- |Buffer| ->- |Consumer| -------- ------ --------- Buffer here to handle case consumer handles slower than provider, data has to temporarily be stored in buffer.
- Example in
stream-example-constructor.jsandstream-example-generator.js
-
-
Pipelining:
+===================+
x--> Piping functions +--> src.pipe(dest) |
x are set up during |===================|
x the .pipe method. | Event callbacks |
+===============+ x |-------------------|
| Your Data | x They exist outside | .on('close', cb) |
+=======+=======+ x the data flow, but | .on('data', cb) |
| x importantly attach | .on('drain', cb) |
| x events, and their | .on('unpipe', cb) |
+---------v---------+ x respective callbacks. | .on('error', cb) |
| Readable Stream +----+ | .on('finish', cb) |
+-^-------^-------^-+ | | .on('end', cb) |
^ | ^ | +-------------------+
| | | |
| ^ | |
^ ^ ^ | +-------------------+ +=================+
^ | ^ +----> Writable Stream +---------> .write(chunk) |
| | | +-------------------+ +=======+=========+
| | | |
| ^ | +------------------v---------+
^ | +-> if (!chunk) | Is this chunk too big? |
^ | | emit .end(); | Is the queue busy? |
| | +-> else +-------+----------------+---+
| ^ | emit .write(); | |
| ^ ^ +--v---+ +---v---+
| | ^-----------------------------------< No | | Yes |
^ | +------+ +---v---+
^ | |
| ^ emit .pause(); +=================+ |
| ^---------------^-----------------------+ return false; <-----+---+
| +=================+ |
| |
^ when queue is empty +============+ |
^------------^-----------------------< Buffering | |
| |============| |
+> emit .drain(); | ^Buffer^ | |
+> emit .resume(); +------------+ |
| ^Buffer^ | |
+------------+ add chunk to queue |
| <---^---------------------<
+============+
5. setTimeout
- Source code:
setTimeout.js - Here we explain how setTimeout work:
- Easily we can see that in this example all blocking code will finish first, and then all console.log inside setTime run later.
- But a question here is how timer in setTimeout is calculated and order of execution of function in setTimeout?
- We know that when a non-blocking run, it push a function to
Event loopand run in an appropriate phase. - In this example, when we call setTime, it means we push a function setTimeout to Event loop and then after a certain time, Event Loop will move this task to Event Queue.
- When call stack (which run all blocking code sequentially) is empty, it will take task in Event Queue to run to the end.
- So it makes us easier to understand why the for loop take more than 10ms, and the setTimeout with timer is 10ms always run after all, even though it is defined before another setTimeout.
- And last, we want to know when the timer in setTimeout is run, take a look at the result of source code example (in my machine).
➜ node setTimeout.js B start 1630648460890 # it take 100s to finish blocking codes Finish blocking 1630648562631 A D # and take 1ms to run last setTimeout End 1630648562632
- So we can see timer is calculated immediately since it defined.
- We know that when a non-blocking run, it push a function to
6. Express, MongoDB test write performance
- Source:
/performace-tests.js