已解決430363個問題，去搜搜看，總會有你想問的

一個nodejs stream詭異的行為, 猜測和事件循環有關系, 求解釋?

首頁猿問一個nodejs...

一個nodejs stream詭異的行為, 猜測和事件循環有關系, 求解釋?

Vue.js Node.js

慕田峪4524236 2019-03-19 18:44:41

當前目錄下準備一個test.txt, 寫入一些東西, 比如>It's for test<分別執行代碼:注釋掉延時為 3 ms的代碼塊, 輸出dest.txt, 內容為>It's for test<注釋掉延時為 2 ms的代碼塊, 輸出dest.txt, 內容為>It's for test<>It's for test<以下為代碼const fs = require('fs')const from = fs.createReadStream('test.txt')const to = fs.createWriteStream('dest.txt', { flags: 'a'})from.pipe(to, { end: false})from.on('end', () => { console.log('end') })// setTimeout(() => {// from.pipe(to)//this won't work, if time >= 3// }, 3)// setTimeout(() => {// from.pipe(to)//this will work, if time < 3// }, 2)只觸發end事件一次不同時間延遲, 輸出不同, 行為十分詭異, 求解釋?

查看完整描述

2 回答

斯蒂芬大帝

TA貢獻1827條經驗獲得超8個贊

通過I/O讀取字符串到緩沖區

timers階段沒有callback執行，寫入WriteStream，timers階段檢測到callback，執行callback，然鵝ReadStream沒數據，pipe沒有效果。
timers階段檢測到callback，執行callback，ReadStream數據還在，pipe有效果。

用process.stdout測試

const fs = require('fs')const from = fs.createReadStream('test.txt')from.pipe(process.stdout, {
    end: false})from.on('end', () => {    console.log('end')
})

setTimeout(() => {    console.log('timer callback')    from.pipe(process.stdout) //this won't work, if time >= 3}, 3)// setTimeout(() => {//     console.log('timer callback')//     from.pipe(process.stdout) //this will work, if time < 3// }, 2)

反對回復 2019-03-19

紅糖糍粑

TA貢獻1815條經驗獲得超6個贊

默認情況下，在源流發出時stream.end()在目標Writable流上調用，以便目標不再可寫。要禁用此默認行為，可以將該選項作為傳遞，從而使目標流保持打開狀態：

reader.pipe(writer, { end: false });

上面說的很清楚了，設置false是保持打開狀態，不是你理解的可以一直編輯，也是有時間限制的
由于Js是異步處理，所有程序同步執行，寫入和settimeout也一樣，所以當你設置延遲時長高的時候，是沒辦法注入進去的。
謝謝

反對回復 2019-03-19

2 回答
0 關注
786 瀏覽

關注

添加回答

舉報

0/150

提交

取消

亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

熱搜

最近搜索清空

一個nodejs stream詭異的行為, 猜測和事件循環有關系, 求解釋?

一個nodejs stream詭異的行為, 猜測和事件循環有關系, 求解釋?

2 回答

添加回答