main.jsdom
let data1 = []; let data2 = []; for (let i = 0;i < 500000;i++) { let j = i * 500.0 / 60000.0; data1.push([j, 200 * Math.random() + 100]); data2.push([j, 400 * Math.random() + 100]); } let params = { type: 'xls', data: { data1, data2 }, filename: 'text.xls', }; let worker = new Worker('worker.js'); worker.onmessage = (ev) => {
console.log('寫入完成'); worker.terminate(); }; worker.postMessage(params);
worker.jselectron
const fs = require( "fs" ); self.onmessage = function (e) { let data = e.data; console.log(data); if (data.type === "xls") { //todo 寫入文件流 let writeStream = fs.createWriteStream(data.filename, { encoding: 'utf8' }); //讀取文件發生錯誤事件 writeStream.on('error', (err) => { console.error('發生異常:', err);
self.postMessage({ success: false, message: err }); }); //已打開要寫入的文件事件 writeStream.on('open', (fd) => { console.log('文件已打開:', fd); let i = 0; let value = "x\ty\ty1\n"; function write() { if (i >= data.data.data1.length) { writeStream.end(); setTimeout(() => {//todo 不知道爲何,當即發送報錯,延遲發送沒問題,這樣electron窗口就不會崩潰 self.postMessage({ success: true, message: 'complete' }); }, 500); return; } value = data.data.data1[i][0] + "\t" + data.data.data1[i][1] + "\t" + data.data.data2[i][1] + "\n";
i++; writeStream.write(value, () => { write(); }); } writeStream.write(value, () => { write(); }); }); //文件已經就寫入完成事件 writeStream.on('finish', () => { console.log('寫入已完成..'); }); //文件關閉事件 writeStream.on('close', () => { console.log('文件已關閉!'); }); } };