From 241880f2b0f264ccdae9644e74afc423ec2fe40a Mon Sep 17 00:00:00 2001 From: Phil Kunz Date: Sat, 4 Mar 2017 12:24:32 +0100 Subject: [PATCH] add forkOptions --- dist/smartipc.classes.threadsimple.d.ts | 3 ++- dist/smartipc.classes.threadsimple.js | 7 ++++--- ts/smartipc.classes.threadsimple.ts | 6 ++++-- 3 files changed, 10 insertions(+), 6 deletions(-) diff --git a/dist/smartipc.classes.threadsimple.d.ts b/dist/smartipc.classes.threadsimple.d.ts index 2fd98e7..0fa2672 100644 --- a/dist/smartipc.classes.threadsimple.d.ts +++ b/dist/smartipc.classes.threadsimple.d.ts @@ -2,6 +2,7 @@ import * as childProcess from 'child_process'; export declare class ThreadSimple { workerPath: string; threadChildProcess: childProcess.ChildProcess; - constructor(filePathArg: string); + forkOptions: childProcess.ForkOptions; + constructor(filePathArg: string, forkOptionsArg?: childProcess.ForkOptions); run(): Promise; } diff --git a/dist/smartipc.classes.threadsimple.js b/dist/smartipc.classes.threadsimple.js index 41808f7..285adc3 100644 --- a/dist/smartipc.classes.threadsimple.js +++ b/dist/smartipc.classes.threadsimple.js @@ -5,8 +5,9 @@ const smartq = require("smartq"); const childProcess = require("child_process"); const smartipc_classes_thread_1 = require("./smartipc.classes.thread"); class ThreadSimple { - constructor(filePathArg) { + constructor(filePathArg, forkOptionsArg = {}) { this.workerPath = filePathArg; + this.forkOptions = forkOptionsArg; } run() { let done = smartq.defer(); @@ -18,10 +19,10 @@ class ThreadSimple { return this.workerPath; } })(); - this.threadChildProcess = childProcess.fork(forkPath); + this.threadChildProcess = childProcess.fork(forkPath, [], this.forkOptions); done.resolve(this.threadChildProcess); return done.promise; } } exports.ThreadSimple = ThreadSimple; -//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMuY2xhc3Nlcy50aHJlYWRzaW1wbGUuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydGlwYy5jbGFzc2VzLnRocmVhZHNpbXBsZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDhDQUE2QztBQUM3QyxpQ0FBZ0M7QUFDaEMsOENBQTZDO0FBRTdDLHVFQUEwRDtBQUUxRDtJQUdFLFlBQWEsV0FBbUI7UUFDOUIsSUFBSSxDQUFDLFVBQVUsR0FBRyxXQUFXLENBQUE7SUFDL0IsQ0FBQztJQUVELEdBQUc7UUFDRCxJQUFJLElBQUksR0FBRyxNQUFNLENBQUMsS0FBSyxFQUE2QixDQUFBO1FBQ3BELElBQUksUUFBUSxHQUFHLENBQUM7WUFDZCxFQUFFLENBQUMsQ0FBQyx3Q0FBYyxDQUFDLENBQUMsQ0FBQztnQkFDbkIsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLHdDQUFjLEVBQUUsSUFBSSxDQUFDLFVBQVUsQ0FBQyxDQUFBO1lBQzNELENBQUM7WUFBQyxJQUFJLENBQUMsQ0FBQztnQkFDTixNQUFNLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQTtZQUN4QixDQUFDO1FBQ0gsQ0FBQyxDQUFDLEVBQUUsQ0FBQTtRQUNKLElBQUksQ0FBQyxrQkFBa0IsR0FBRyxZQUFZLENBQUMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxDQUFBO1FBQ3JELElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGtCQUFrQixDQUFDLENBQUE7UUFDckMsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUE7SUFDckIsQ0FBQztDQUNGO0FBcEJELG9DQW9CQyJ9 \ No newline at end of file +//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRpcGMuY2xhc3Nlcy50aHJlYWRzaW1wbGUuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydGlwYy5jbGFzc2VzLnRocmVhZHNpbXBsZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDhDQUE2QztBQUM3QyxpQ0FBZ0M7QUFDaEMsOENBQTZDO0FBRTdDLHVFQUEwRDtBQUUxRDtJQUlFLFlBQWEsV0FBbUIsRUFBRSxpQkFBMkMsRUFBRTtRQUM3RSxJQUFJLENBQUMsVUFBVSxHQUFHLFdBQVcsQ0FBQTtRQUM3QixJQUFJLENBQUMsV0FBVyxHQUFHLGNBQWMsQ0FBQTtJQUNuQyxDQUFDO0lBRUQsR0FBRztRQUNELElBQUksSUFBSSxHQUFHLE1BQU0sQ0FBQyxLQUFLLEVBQTZCLENBQUE7UUFDcEQsSUFBSSxRQUFRLEdBQUcsQ0FBQztZQUNkLEVBQUUsQ0FBQyxDQUFDLHdDQUFjLENBQUMsQ0FBQyxDQUFDO2dCQUNuQixNQUFNLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsd0NBQWMsRUFBRSxJQUFJLENBQUMsVUFBVSxDQUFDLENBQUE7WUFDM0QsQ0FBQztZQUFDLElBQUksQ0FBQyxDQUFDO2dCQUNOLE1BQU0sQ0FBQyxJQUFJLENBQUMsVUFBVSxDQUFBO1lBQ3hCLENBQUM7UUFDSCxDQUFDLENBQUMsRUFBRSxDQUFBO1FBQ0osSUFBSSxDQUFDLGtCQUFrQixHQUFHLFlBQVksQ0FBQyxJQUFJLENBQUMsUUFBUSxFQUFFLEVBQUUsRUFBRSxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUE7UUFDM0UsSUFBSSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsa0JBQWtCLENBQUMsQ0FBQTtRQUNyQyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtJQUNyQixDQUFDO0NBQ0Y7QUF0QkQsb0NBc0JDIn0= \ No newline at end of file diff --git a/ts/smartipc.classes.threadsimple.ts b/ts/smartipc.classes.threadsimple.ts index ffdd886..14557fe 100644 --- a/ts/smartipc.classes.threadsimple.ts +++ b/ts/smartipc.classes.threadsimple.ts @@ -7,8 +7,10 @@ import { workerBasePath } from './smartipc.classes.thread' export class ThreadSimple { workerPath: string threadChildProcess: childProcess.ChildProcess - constructor (filePathArg: string) { + forkOptions: childProcess.ForkOptions + constructor (filePathArg: string, forkOptionsArg: childProcess.ForkOptions = {}) { this.workerPath = filePathArg + this.forkOptions = forkOptionsArg } run () { @@ -20,7 +22,7 @@ export class ThreadSimple { return this.workerPath } })() - this.threadChildProcess = childProcess.fork(forkPath) + this.threadChildProcess = childProcess.fork(forkPath, [], this.forkOptions) done.resolve(this.threadChildProcess) return done.promise }