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