| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent dfa4444 commit 0bd9704
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -54,7 +54,7 @@ const { | |||
| 54 | 54 | } = require('internal/validators'); | |
| 55 | 55 | const { setTimeout } = require('timers/promises'); | |
| 56 | 56 | const { TIMEOUT_MAX } = require('internal/timers'); | |
| 57 | - const { cpus } = require('os'); | ||
| 57 | + const { availableParallelism } = require('os'); | ||
| 58 | 58 | const { bigint: hrtime } = process.hrtime; | |
| 59 | 59 | const kCallbackAndPromisePresent = 'callbackAndPromisePresent'; | |
| 60 | 60 | const kCancelledByParent = 'cancelledByParent'; | |
@@ -231,8 +231,8 @@ class Test extends AsyncResource { | |||
| 231 | 231 | ||
| 232 | 232 | case 'boolean': | |
| 233 | 233 | if (concurrency) { | |
| 234 | - // TODO(cjihrig): Use uv_available_parallelism() once it lands. | ||
| 235 | - this.concurrency = parent === null ? MathMax(cpus().length - 1, 1) : Infinity; | ||
| 234 | + this.concurrency = parent === null ? | ||
| 235 | + MathMax(availableParallelism() - 1, 1) : Infinity; | ||
| 236 | 236 | } else { | |
| 237 | 237 | this.concurrency = 1; | |
| 238 | 238 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments