worker timeout

src/renderer/src/utils/drpy/index.ts

@@ -1,12 +1,13 @@
-import Worker from '@/utils/drpy/worker?worker';   
+import Worker from '@/utils/drpy/worker?worker';
 
-let worker = new Worker();
+let worker: Worker = new Worker();
+let timer: any = null;
 
 const doWork = (data) => {
   return new Promise((resolve, reject) => {
     worker.onmessage = (event) => {
       const response = event.data;
-      console.log(response)
+      if (response) clearInterval(timer);
       resolve(response);
     };
 
@@ -15,14 +16,21 @@ const doWork = (data) => {
     };
 
     worker.postMessage(data);
+
+    timer = setTimeout(async () => {
+      worker.terminate();
+      worker = new Worker();
+      reject(new Error('Worker job run 15s, timed out'));
+    }, 15000);
   });
 }
 
 const terminateWork = () => {
   return new Promise((resolve, reject) => {
+    if (timer) clearInterval(timer);
     if (typeof worker !== 'undefined' && worker !== null) {
       worker.terminate();
-      worker = new Worker(); // 重新创建
+      worker = new Worker();
       resolve({
         msg: 'Worker terminated successfully.',
         code: 200
@@ -36,4 +44,4 @@ const terminateWork = () => {
   });
 };
 
-export { doWork, terminateWork };
+export { doWork, terminateWork };