push.rocks/smartspawn
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add forkOptions

Browse Source
This commit is contained in:
Philipp Kunz 2017-03-04 12:24:32 +01:00
parent 9d33a5df53
commit 241880f2b0
3 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dist/smartipc.classes.threadsimple.d.ts vendored
View File

@ -2,6 +2,7 @@ import * as childProcess from 'child_process';
export declare class ThreadSimple { export declare class ThreadSimple {
workerPath: string; workerPath: string;
threadChildProcess: childProcess.ChildProcess; threadChildProcess: childProcess.ChildProcess;
constructor(filePathArg: string); forkOptions: childProcess.ForkOptions;
constructor(filePathArg: string, forkOptionsArg?: childProcess.ForkOptions);
run(): Promise<childProcess.ChildProcess>; run(): Promise<childProcess.ChildProcess>;
} }

7
dist/smartipc.classes.threadsimple.js vendored
View File

@ -5,8 +5,9 @@ const smartq = require("smartq");
const childProcess = require("child_process"); const childProcess = require("child_process");
const smartipc_classes_thread_1 = require("./smartipc.classes.thread"); const smartipc_classes_thread_1 = require("./smartipc.classes.thread");
class ThreadSimple { class ThreadSimple {
constructor(filePathArg) { constructor(filePathArg, forkOptionsArg = {}) {
this.workerPath = filePathArg; this.workerPath = filePathArg;
this.forkOptions = forkOptionsArg;
} }
run() { run() {
let done = smartq.defer(); let done = smartq.defer();
@ -18,10 +19,10 @@ class ThreadSimple {
return this.workerPath; return this.workerPath;
} }
})(); })();
this.threadChildProcess = childProcess.fork(forkPath); this.threadChildProcess = childProcess.fork(forkPath, [], this.forkOptions);
done.resolve(this.threadChildProcess); done.resolve(this.threadChildProcess);
return done.promise; return done.promise;
} }
} }
exports.ThreadSimple = ThreadSimple; exports.ThreadSimple = ThreadSimple;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMuY2xhc3Nlcy50aHJlYWRzaW1wbGUuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydGlwYy5jbGFzc2VzLnRocmVhZHNpbXBsZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDhDQUE2QztBQUM3QyxpQ0FBZ0M7QUFDaEMsOENBQTZDO0FBRTdDLHVFQUEwRDtBQUUxRDtJQUdFLFlBQWEsV0FBbUI7UUFDOUIsSUFBSSxDQUFDLFVBQVUsR0FBRyxXQUFXLENBQUE7SUFDL0IsQ0FBQztJQUVELEdBQUc7UUFDRCxJQUFJLElBQUksR0FBRyxNQUFNLENBQUMsS0FBSyxFQUE2QixDQUFBO1FBQ3BELElBQUksUUFBUSxHQUFHLENBQUM7WUFDZCxFQUFFLENBQUMsQ0FBQyx3Q0FBYyxDQUFDLENBQUMsQ0FBQztnQkFDbkIsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLHdDQUFjLEVBQUUsSUFBSSxDQUFDLFVBQVUsQ0FBQyxDQUFBO1lBQzNELENBQUM7WUFBQyxJQUFJLENBQUMsQ0FBQztnQkFDTixNQUFNLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQTtZQUN4QixDQUFDO1FBQ0gsQ0FBQyxDQUFDLEVBQUUsQ0FBQTtRQUNKLElBQUksQ0FBQyxrQkFBa0IsR0FBRyxZQUFZLENBQUMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxDQUFBO1FBQ3JELElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGtCQUFrQixDQUFDLENBQUE7UUFDckMsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7SUFDckIsQ0FBQztDQUNGO0FBcEJELG9DQW9CQyJ9 //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMuY2xhc3Nlcy50aHJlYWRzaW1wbGUuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydGlwYy5jbGFzc2VzLnRocmVhZHNpbXBsZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDhDQUE2QztBQUM3QyxpQ0FBZ0M7QUFDaEMsOENBQTZDO0FBRTdDLHVFQUEwRDtBQUUxRDtJQUlFLFlBQWEsV0FBbUIsRUFBRSxpQkFBMkMsRUFBRTtRQUM3RSxJQUFJLENBQUMsVUFBVSxHQUFHLFdBQVcsQ0FBQTtRQUM3QixJQUFJLENBQUMsV0FBVyxHQUFHLGNBQWMsQ0FBQTtJQUNuQyxDQUFDO0lBRUQsR0FBRztRQUNELElBQUksSUFBSSxHQUFHLE1BQU0sQ0FBQyxLQUFLLEVBQTZCLENBQUE7UUFDcEQsSUFBSSxRQUFRLEdBQUcsQ0FBQztZQUNkLEVBQUUsQ0FBQyxDQUFDLHdDQUFjLENBQUMsQ0FBQyxDQUFDO2dCQUNuQixNQUFNLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsd0NBQWMsRUFBRSxJQUFJLENBQUMsVUFBVSxDQUFDLENBQUE7WUFDM0QsQ0FBQztZQUFDLElBQUksQ0FBQyxDQUFDO2dCQUNOLE1BQU0sQ0FBQyxJQUFJLENBQUMsVUFBVSxDQUFBO1lBQ3hCLENBQUM7UUFDSCxDQUFDLENBQUMsRUFBRSxDQUFBO1FBQ0osSUFBSSxDQUFDLGtCQUFrQixHQUFHLFlBQVksQ0FBQyxJQUFJLENBQUMsUUFBUSxFQUFFLEVBQUUsRUFBRSxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUE7UUFDM0UsSUFBSSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsa0JBQWtCLENBQUMsQ0FBQTtRQUNyQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtJQUNyQixDQUFDO0NBQ0Y7QUF0QkQsb0NBc0JDIn0=

6
ts/smartipc.classes.threadsimple.ts
View File

@ -7,8 +7,10 @@ import { workerBasePath } from './smartipc.classes.thread'
export class ThreadSimple { export class ThreadSimple {
workerPath: string workerPath: string
threadChildProcess: childProcess.ChildProcess threadChildProcess: childProcess.ChildProcess
constructor (filePathArg: string) { forkOptions: childProcess.ForkOptions
constructor (filePathArg: string, forkOptionsArg: childProcess.ForkOptions = {}) {
this.workerPath = filePathArg this.workerPath = filePathArg
this.forkOptions = forkOptionsArg
} }
run () { run () {
@ -20,7 +22,7 @@ export class ThreadSimple {
return this.workerPath return this.workerPath
} }
})() })()
this.threadChildProcess = childProcess.fork(forkPath) this.threadChildProcess = childProcess.fork(forkPath, [], this.forkOptions)
done.resolve(this.threadChildProcess) done.resolve(this.threadChildProcess)
return done.promise return done.promise
} }