ファイルストリームを1行ずつ同期して読み込みます。

Question

私はノードごとにreadlineというモジュールドキュメントを見て、非常に大きなファイルを1行ずつ読み込んでいます。しかし、私の特別な仕事のために、私はそれを同期して行を読む必要があります。関係なく何を、5行目は、4行目の前に読まれてはならない、とによるノードの性質のために、私はちょうどそれがその使用のために安全で、このコードで確認したい -

const readline = require('readline'); 
const fs = require('fs'); 

const rl = readline.createInterface({ 
    input: fs.createReadStream('sample.txt') 
}); 

rl.on('line', (line) => { 
    console.log(`Line from file: ${line}`); 
}); 

ない場合、私は何を使用する必要があります/行う？現在私のために働いていますが、次の行が前の行よりも速く解析できる大きな行で動作するかどうかわかりません。

Answer 1

コールバックが起動する可能性は非常に疑いがあります後で他のものより早く実行することができます。 基本的には、event loopを参照し、プロセスをスタックします。

でも、私はasync/queueと似たようなものを実装することを推奨できますが、コールバックを動的にプッシュすることは可能です。

rl.on('line', (line) => { 
    addLineToQueue(line) 
    console.log(`Added line to queue: ${line}`) 
}) 

そして、あなたのキューの実装は限りそれが実行するすべてのタスクを持っているとして起動する必要があります確認してください：あなたは、あなたのコードを変更します

const Queue = require('./my-queue') 
const queue = new Queue() 

function addLineToQueue(line) { 
    queue.push(function() { 
    // do some job with line 
    console.log(`Line: "${line}" was successfully processed!`) 
    }) 
} 

：あなたはこのような何かを持っているだろうと仮定

。このようにコールバックの順序が保証されます。しかし、私にとっては少しオーバーヘッドのように見えます。