WPoll

Worker poll use worker_threads

Example

• main.ts

import { WPoll } from 'wpoll';
import path from 'path';

let wpoll = new WPoll<number>(path.resolve(__dirname, './worker.js'));
wpoll.init();

(async () => {
    console.log(await wpoll.exec(100));
})();

• worker.ts

import { WWorker } from 'wpoll';

new WWorker(async (message) => {
    console.log(message);
    return 5;
});

Types

WPoll<T = void, P = void>

|Name|Parameter|Type|Description| |---|---|---|---| |Constructor||WPoll<T, P>| ||workerFile|string|Path to worker file (absolute path preferred)| ||props|WPollProps|Init Parameters |init|-|-|Init Workers. Must be called once| |exec|T|P|Execute with parameters T and return P

WWorker<T = void, P = void>

|Name|Parameter|Type|Description| |---|---|---|---| |Constructor||WWorker<T,P> ||onMessage|(message: T) => Promise<P> | P| callback on message received