Skip to content

Commit

Permalink
lib: make queueMicrotask faster
Browse files Browse the repository at this point in the history
No longer create an additional scope within queueMicrotask
in order to improve performance.

PR-URL: #27032
Reviewed-By: Gus Caplan <[email protected]>
Reviewed-By: Ruben Bridgewater <[email protected]>
Reviewed-By: James M Snell <[email protected]>
  • Loading branch information
apapirovski authored and danbev committed Apr 5, 2019
1 parent d3d4e10 commit 2c49e8b
Show file tree
Hide file tree
Showing 3 changed files with 59 additions and 15 deletions.
21 changes: 21 additions & 0 deletions benchmark/process/queue-microtask-breadth.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
'use strict';

const common = require('../common.js');
const bench = common.createBenchmark(main, {
n: [4e5]
});

function main({ n }) {
var j = 0;

function cb() {
j++;
if (j === n)
bench.end(n);
}

bench.start();
for (var i = 0; i < n; i++) {
queueMicrotask(cb);
}
}
17 changes: 17 additions & 0 deletions benchmark/process/queue-microtask-depth.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
'use strict';
const common = require('../common.js');
const bench = common.createBenchmark(main, {
n: [12e5]
});

function main({ n }) {
let counter = n;
bench.start();
queueMicrotask(onNextTick);
function onNextTick() {
if (--counter)
queueMicrotask(onNextTick);
else
bench.end(n);
}
}
36 changes: 21 additions & 15 deletions lib/internal/process/task_queues.js
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,8 @@ const {
} = require('internal/errors').codes;
const FixedQueue = require('internal/fixed_queue');

const FunctionBind = Function.call.bind(Function.prototype.bind);

// *Must* match Environment::TickInfo::Fields in src/env.h.
const kHasTickScheduled = 0;

Expand Down Expand Up @@ -149,28 +151,32 @@ function createMicrotaskResource() {
});
}

function runMicrotask() {
this.runInAsyncScope(() => {
const callback = this.callback;
try {
callback();
} catch (error) {
// TODO(devsnek) remove this if
// https://bugs.chromium.org/p/v8/issues/detail?id=8326
// is resolved such that V8 triggers the fatal exception
// handler for microtasks
triggerFatalException(error);
} finally {
this.emitDestroy();
}
});
}

function queueMicrotask(callback) {
if (typeof callback !== 'function') {
throw new ERR_INVALID_ARG_TYPE('callback', 'function', callback);
}

const asyncResource = createMicrotaskResource();
asyncResource.callback = callback;

enqueueMicrotask(() => {
asyncResource.runInAsyncScope(() => {
try {
callback();
} catch (error) {
// TODO(devsnek) remove this if
// https://bugs.chromium.org/p/v8/issues/detail?id=8326
// is resolved such that V8 triggers the fatal exception
// handler for microtasks
triggerFatalException(error);
} finally {
asyncResource.emitDestroy();
}
});
});
enqueueMicrotask(FunctionBind(runMicrotask, asyncResource));
}

module.exports = {
Expand Down

0 comments on commit 2c49e8b

Please sign in to comment.