chore: use os.availableParallelism when available

.yarn/versions/cad178bf.yml

@@ -0,0 +1,34 @@
+releases:
+  "@yarnpkg/cli": patch
+  "@yarnpkg/core": patch
+  "@yarnpkg/plugin-workspace-tools": patch
+
+declined:
+  - "@yarnpkg/plugin-compat"
+  - "@yarnpkg/plugin-constraints"
+  - "@yarnpkg/plugin-dlx"
+  - "@yarnpkg/plugin-essentials"
+  - "@yarnpkg/plugin-exec"
+  - "@yarnpkg/plugin-file"
+  - "@yarnpkg/plugin-git"
+  - "@yarnpkg/plugin-github"
+  - "@yarnpkg/plugin-http"
+  - "@yarnpkg/plugin-init"
+  - "@yarnpkg/plugin-interactive-tools"
+  - "@yarnpkg/plugin-link"
+  - "@yarnpkg/plugin-nm"
+  - "@yarnpkg/plugin-npm"
+  - "@yarnpkg/plugin-npm-cli"
+  - "@yarnpkg/plugin-pack"
+  - "@yarnpkg/plugin-patch"
+  - "@yarnpkg/plugin-pnp"
+  - "@yarnpkg/plugin-pnpm"
+  - "@yarnpkg/plugin-stage"
+  - "@yarnpkg/plugin-typescript"
+  - "@yarnpkg/plugin-version"
+  - "@yarnpkg/builder"
+  - "@yarnpkg/doctor"
+  - "@yarnpkg/extensions"
+  - "@yarnpkg/nm"
+  - "@yarnpkg/pnpify"
+  - "@yarnpkg/sdks"

packages/plugin-workspace-tools/sources/commands/foreach.ts

@@ -1,11 +1,10 @@
 import {BaseCommand, WorkspaceRequiredError}                         from '@yarnpkg/cli';
 import {Configuration, LocatorHash, Project, scriptUtils, Workspace} from '@yarnpkg/core';
 import {DescriptorHash, MessageName, Report, StreamReport}           from '@yarnpkg/core';
-import {formatUtils, miscUtils, structUtils}                         from '@yarnpkg/core';
+import {formatUtils, miscUtils, structUtils, nodeUtils}              from '@yarnpkg/core';
 import {gitUtils}                                                    from '@yarnpkg/plugin-git';
 import {Command, Option, Usage, UsageError}                          from 'clipanion';
 import micromatch                                                    from 'micromatch';
-import {cpus}                                                        from 'os';
 import pLimit                                                        from 'p-limit';
 import {Writable}                                                    from 'stream';
 import {WriteStream}                                                 from 'tty';
@@ -200,7 +199,7 @@ export default class WorkspacesForeachCommand extends BaseCommand {
     const concurrency = this.parallel ?
       (this.jobs === `unlimited`
         ? Infinity
-        : Number(this.jobs) || Math.max(1, cpus().length / 2))
+        : Number(this.jobs) || Math.ceil(nodeUtils.availableParallelism() / 2))
       : 1;
 
     // No need to parallelize if we were explicitly asked for one job

packages/yarnpkg-core/sources/WorkerPool.ts

@@ -1,6 +1,7 @@
-import {cpus}   from 'os';
-import PLimit   from 'p-limit';
-import {Worker} from 'worker_threads';
+import PLimit         from 'p-limit';
+import {Worker}       from 'worker_threads';
+
+import * as nodeUtils from './nodeUtils';
 
 const kTaskInfo = Symbol(`kTaskInfo`);
 
@@ -10,7 +11,7 @@ type PoolWorker<TOut> = Worker & {
 
 export class WorkerPool<TIn, TOut> {
   private workers: Array<PoolWorker<TOut>> = [];
-  private limit = PLimit(Math.max(1, cpus().length));
+  private limit = PLimit(nodeUtils.availableParallelism());
   private cleanupInterval: ReturnType<typeof setInterval>;
 
   constructor(private source: string) {

packages/yarnpkg-core/sources/nodeUtils.ts

@@ -1,5 +1,6 @@
 import {ppath}        from '@yarnpkg/fslib';
 import Module         from 'module';
+import os             from 'os';
 
 import * as execUtils from './execUtils';
 import * as miscUtils from './miscUtils';
@@ -136,3 +137,12 @@ export function getCaller() {
 
   return parseStackLine(line);
 }
+
+export function availableParallelism() {
+  // TODO: Use os.availableParallelism directly when dropping support for Node.js < 19.4.0
+  if (`availableParallelism` in os)
+    // @ts-expect-error - No types yet
+    return os.availableParallelism();
+
+  return Math.max(1, os.cpus().length);
+}