OSSForks/node
1
0
Fork 0
mirror of https://github.com/zebrajr/node.git synced 2026-01-15 12:15:26 +00:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

doc: use os.availableParallelism() in async_context and cluster

Browse Source 
Refs: https://github.com/nodejs/node/pull/45895
PR-URL: https://github.com/nodejs/node/pull/45979
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Moshe Atlow <moshe@atlow.co.il>
Reviewed-By: Mohammed Keyvanzadeh <mohammadkeyvanzade94@gmail.com>
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
This commit is contained in:
Deokjin Kim
2022-12-28 20:45:10 +09:00
committed by GitHub
parent 5754e04c9f
commit 6d8c5a4580
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
doc/api/async_context.md
View File

@@ -762,7 +762,7 @@ This pool could be used as follows:
import WorkerPool from './worker_pool.js';
import os from 'node:os';
const pool = new WorkerPool(os.cpus().length);
const pool = new WorkerPool(os.availableParallelism());
let finished = 0;
for (let i = 0; i < 10; i++) {
@@ -778,7 +778,7 @@ for (let i = 0; i < 10; i++) {
const WorkerPool = require('./worker_pool.js');
const os = require('node:os');
const pool = new WorkerPool(os.cpus().length);
const pool = new WorkerPool(os.availableParallelism());
let finished = 0;
for (let i = 0; i < 10; i++) {

18
doc/api/cluster.md
View File

@@ -17,10 +17,10 @@ server ports.
```mjs
import cluster from 'node:cluster';
import http from 'node:http';
import { cpus } from 'node:os';
import { availableParallelism } from 'node:os';
import process from 'node:process';
const numCPUs = cpus().length;
const numCPUs = availableParallelism();
if (cluster.isPrimary) {
console.log(`Primary ${process.pid} is running`);
@@ -48,7 +48,7 @@ if (cluster.isPrimary) {
```cjs
const cluster = require('node:cluster');
const http = require('node:http');
const numCPUs = require('node:os').cpus().length;
const numCPUs = require('node:os').availableParallelism();
const process = require('node:process');
if (cluster.isPrimary) {
@@ -273,7 +273,7 @@ process of the number of HTTP requests received by the workers:
```mjs
import cluster from 'node:cluster';
import http from 'node:http';
import { cpus } from 'node:os';
import { availableParallelism } from 'node:os';
import process from 'node:process';
if (cluster.isPrimary) {
@@ -292,7 +292,7 @@ if (cluster.isPrimary) {
}
// Start workers and listen for messages containing notifyRequest
const numCPUs = cpus().length;
const numCPUs = availableParallelism();
for (let i = 0; i < numCPUs; i++) {
cluster.fork();
}
@@ -335,7 +335,7 @@ if (cluster.isPrimary) {
}
// Start workers and listen for messages containing notifyRequest
const numCPUs = require('node:os').cpus().length;
const numCPUs = require('node:os').availableParallelism();
for (let i = 0; i < numCPUs; i++) {
cluster.fork();
}
@@ -507,10 +507,10 @@ because of exiting or being signaled). Otherwise, it returns `false`.
```mjs
import cluster from 'node:cluster';
import http from 'node:http';
import { cpus } from 'node:os';
import { availableParallelism } from 'node:os';
import process from 'node:process';
const numCPUs = cpus().length;
const numCPUs = availableParallelism();
if (cluster.isPrimary) {
console.log(`Primary ${process.pid} is running`);
@@ -540,7 +540,7 @@ if (cluster.isPrimary) {
```cjs
const cluster = require('node:cluster');
const http = require('node:http');
const numCPUs = require('node:os').cpus().length;
const numCPUs = require('node:os').availableParallelism();
const process = require('node:process');
if (cluster.isPrimary) {