32 lines
976 B
TypeScript
32 lines
976 B
TypeScript
import * as plugins from './smartipc.plugins'
|
|
import * as smartq from 'smartq'
|
|
import * as childProcess from 'child_process'
|
|
|
|
import { workerBasePath } from './smartipc.classes.thread'
|
|
|
|
export class ThreadSimple {
|
|
workerPath: string
|
|
threadChildProcess: childProcess.ChildProcess
|
|
forkOptions: childProcess.ForkOptions
|
|
argvArgs: string[]
|
|
constructor (filePathArg: string, argvArgs: string[] = [], forkOptionsArg: childProcess.ForkOptions = {}) {
|
|
this.workerPath = filePathArg
|
|
this.forkOptions = forkOptionsArg
|
|
this.argvArgs = argvArgs
|
|
}
|
|
|
|
run () {
|
|
let done = smartq.defer<childProcess.ChildProcess>()
|
|
let forkPath = (() => {
|
|
if (workerBasePath) {
|
|
return plugins.path.join(workerBasePath, this.workerPath)
|
|
} else {
|
|
return this.workerPath
|
|
}
|
|
})()
|
|
this.threadChildProcess = childProcess.fork(forkPath, this.argvArgs, this.forkOptions)
|
|
done.resolve(this.threadChildProcess)
|
|
return done.promise
|
|
}
|
|
}
|