ElectronJS中渲染进程调用主进程多线程函数的IPC实践

// src/service/worker.js - 这是一个threads.js的工作线程脚本
// 此文件将在独立的Node.js线程中执行
module.exports = function(text) {
  return new Promise(resolve => {
    // 模拟一个耗时的操作，例如文件处理、复杂计算等
    setTimeout(() => {
      const processedText = `Processed by worker: ${text.toUpperCase()} at ${new Date().toISOString()}`;
      resolve(processedText);
    }, 1500); // 模拟1.5秒的工作
  });
};

// main.js - 主进程文件
const { app, BrowserWindow, ipcMain } = require('electron');
const path = require('path');
const { spawn, Worker, Thread } = require('threads');

// ... (其他Electron应用初始化代码，如创建窗口等) ...

/**
 * 异步执行文件发送逻辑，通过工作线程处理
 * @param {string} text - 需要处理的文本数据
 * @returns {Promise<any>} 工作线程返回的结果
 */
const sendFile = async (text) => {
    let sendWorker;
    try {
        // 使用threads.js创建并启动一个工作线程
        // Worker的路径是相对于主进程的
        sendWorker = await spawn(new Worker('./src/service/worker.js'));
        // 调用工作线程中导出的函数，并传递数据
        const result = await sendWorker(text);
        console.log('Worker execution result:', result);
        return result;
    } catch (error) {
        console.error('Error during worker execution:', error);
        throw error; // 抛出错误以便上层捕获
    } finally {
        // 确保工作线程在任务完成后被终止，以释放系统资源
        if (sendWorker) {
            await Thread.terminate(sendWorker);
        }
    }
};

// renderer.js - 渲染进程脚本
const { ipcRenderer } = require('electron');

/**
 * 从渲染进程向主进程发送请求，触发主进程的文件发送逻辑
 * @param {string} dataToSend - 需要发送给主进程的数据
 */
const triggerMainProcessSendFile = (dataToSend) => {
    // 'trigger-send-file' 是我们自定义的IPC通道名称
    ipcRenderer.send('trigger-send-file', dataToSend);
    console.log('Sent message to main process via IPC:', dataToSend);
};

// 示例：当用户点击一个按钮时触发
// document.getElementById('myButton').addEventListener('click', () => {
//   triggerMainProcessSendFile('Hello from render process!');
// });

// main.js (续)
// 主进程监听来自渲染进程的'trigger-send-file'通道消息
ipcMain.on('trigger-send-file', async (event, data) => {
    console.log('Received message from render process to trigger sendFile:', data);
    try {
        // 调用之前定义的主进程多线程函数
        const result = await sendFile(data);
        // 将成功结果回传给渲染进程，使用'send-file-reply'通道
        event.reply('send-file-reply', { success: true, data: result });
    } catch (error) {
        console.error('Failed to execute sendFile from IPC:', error);
        // 将错误信息回传给渲染进程
        event.reply('send-file-reply', { success: false, error: error.message });
    }
});

// renderer.js (续)
// 监听来自主进程的'send-file-reply'通道消息
ipcRenderer.on('send-file-reply', (event, response) => {
    if (response.success) {
        console.log('Received successful reply from main process:', response.data);
        //