WIP - this commit does not work, threadsjs is likely needs to be incorporated into our libraries and rewritten

Author: CMCDragonkai

package-lock.json

@@ -40,7 +40,8 @@
     "@matrixai/async-init": "^2.0.0",
     "@matrixai/errors": "^2.0.1",
     "@matrixai/logger": "^4.0.1",
-    "threads": "^1.7.0"
+    "threads": "^1.7.0",
+    "ts-node": "^10.9.1"
   },
   "devDependencies": {
     "@swc/core": "^1.3.76",

package.json

@@ -1,12 +1,15 @@
-import type { ModuleThread } from 'threads';
-import type { ModuleMethods } from 'threads/dist/types/master';
 import type WorkerManagerInterface from './WorkerManagerInterface.js';
-import type { QueuedTask } from 'threads/dist/master/pool-types';
-import { Pool } from 'threads';
+import type {
+  ModuleMethods,
+  ModuleThread,
+  QueuedTask,
+} from './types.js';
 import Logger from '@matrixai/logger';
 import { CreateDestroy, ready } from '@matrixai/async-init/CreateDestroy.js';
+import { Pool } from 'threads';
 import * as errors from './errors.js';
 
+
 @CreateDestroy()
 class WorkerManager<W extends ModuleMethods>
   implements WorkerManagerInterface<W>

src/WorkerManager.ts

@@ -1,6 +1,8 @@
-import type { ModuleThread } from 'threads';
-import type { ModuleMethods } from 'threads/dist/types/master';
-import type { QueuedTask } from 'threads/dist/master/pool-types';
+import type {
+  ModuleMethods,
+  ModuleThread,
+  QueuedTask,
+} from './types.js';
 
 interface WorkerManagerInterface<W extends ModuleMethods> {
   destroy(options?: { force?: boolean }): Promise<void>;

src/WorkerManagerInterface.ts

@@ -3,4 +3,5 @@ export { default as workerModule } from './workerModule.js';
 export * as errors from './errors.js';
 
 export type { default as WorkerManagerInterface } from './WorkerManagerInterface.js';
-export type { WorkerModule } from './workerModule.js';
+// export type { WorkerModule } from './workerModule.js';
+export type { ModuleMethods, ModuleThread, QueuedTask } from './types.js';

src/index.ts

@@ -6,4 +6,4 @@ import worker from '../src/workerModule.js';
 
 expose(worker);
 
-export type { WorkerModule } from '../src/workerModule.js';
+export type { WorkerModule } from '../src/oldworkerModule.js';