/
githubmirror
/
node
Обзор
Документация
Войти
/
githubmirror
/
node
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
benchmark/fs/readfile-promises.js
82 строки
2 KB
Vinicius Lourenço
benchmark: fix race condition on fs benchs
15 окт 2023, 13:55
Не верифицирован
15 окт 2023, 13:55
33c87ec
Код
Авторство
О чём код?
// Call fs.promises.readFile over and over again really fast. // Then see how many times it got called. // Yes, this is a silly benchmark. Most benchmarks are silly. 'use strict'; const common = require('../common.js'); const fs = require('fs'); const tmpdir = require('../../test/common/tmpdir'); tmpdir.refresh(); const filename = tmpdir.resolve(`.removeme-benchmark-garbage-${process.pid}`); const bench = common.createBenchmark(main, { duration: [5], encoding: ['', 'utf-8'], len: [ 1024, 512 * 1024, 4 * 1024 ** 2, 8 * 1024 ** 2, 16 * 1024 ** 2, 32 * 1024 ** 2, ], concurrent: [1, 10], }); function main({ len, duration, concurrent, encoding }) { try { fs.unlinkSync(filename); } catch { // Continue regardless of error. } let data = Buffer.alloc(len, 'x'); fs.writeFileSync(filename, data); data = null; let reads = 0; let waitConcurrent = 0; const startedAt = Date.now(); const endAt = startedAt + (duration * 1000); bench.start(); function stop() { bench.end(reads); try { fs.unlinkSync(filename); } catch { // Continue regardless of error. } process.exit(0); } function read() { fs.promises.readFile(filename, encoding) .then((res) => afterRead(undefined, res)) .catch((err) => afterRead(err)); } function afterRead(er, data) { if (er) { throw er; } if (data.length !== len) throw new Error('wrong number of bytes returned'); reads++; const benchEnded = Date.now() >= endAt; if (benchEnded && (++waitConcurrent) === concurrent) { stop(); } else if (!benchEnded) { read(); } } for (let i = 0; i < concurrent; i++) read(); }