fork-func
Executes a function in a child process, as easy as simply calling it ;-)
usage
npm install fork-func --save
fork = require 'fork-func' fork './myFunc'args... # external fork myFuncargs... # by reference
calling external source
# function script './heavy-func' = # some heavy, long running stuff return result # main script './main' fork = require 'fork-func' fork './heavy-func'arg0arg1... if error consolelog error else consolelog result
calling functions by reference
You also can execute a function, existing somewhere in your code, in a child process.
This only works, if the function doesn't use references to an outer scope and is done by performing a toSreing()
on the function and using eval()
in the child process to execute the function.
# blocking function = start = Datenow while Datenow - start < delay null delay + 'ms later ... ' + msg fork = require 'fork-func' fork wait1000'not blocked' if error consolelog error else consolelog result # logs: 1000ms later ... not blocked
signature
cp = fork pathOrFuncargs...callback
pathOrFunc
You can pass an absolute or relative path to a module, exporting a function.
If relative, it must be relative to the calling module like you would do in require
.
You can also reference node_modules by their name like you would do in require
.
If the function is a named export of a module you can append the name separated by ::
to the path.
For example, if you have a module './a'
exporting a function b
, you can do:
fork './a::b', arg0, arg1, ..., callback
If you pass a function, this function will be called in a child process.
args...
Any number of arguments, you want to pass to the function. The values you use must be serializable by JSON.stringify.
callback
A function expecting two arguments. First a possible error and second the result of the function call.
return
The child-process instance is returned. You can use it, to kill the processor or do other stuff.
That's it ;-)
But wait...
What, if the function we want to call itself is asynchronous and the result is unknown, when the function returns.
For example, can we use setTimeout
?
async
# function script './heavy-async-func' - could also be inlined module = setTimeout # we now know, what we want to return delay null # we don't know, what to return
We can simply do this:
# main script './main' fork = require 'fork-func' forkasync './heavy-async-func'1000arg1... if error consolelog error else consolelog result
Looks similar to the synchronous version, except that we call async
on fork-func, doesn't it?
But we have to do one more thing:
# function script './heavy-async-func' - could also be inlined module = setTimeout # if we had an error # error = 'we had a bad error!' callback error'we now know, what we want to return' delay null # we don't know, what to return # the passed callback has the same signature as the callback passed to fork-func: =
You can expect (and have to use) that callback in your function when you call fork-func.async
.
And whatever your function returns will be ignored (i currently can't find any reasonable task for the returned value, within this asynchronous variant).
Ok, one more sugar.
You can decorate any object with simpler to use functions like so:
pimp
obj = forkpimp obj'./heavy-func'async # creates a method 'heavyFunc' on obj which you can call without the path argument # async = true creates a fork.async version # async = false creates a fork.sync version # async = undefined/null creates the normal fork version objheavyFunc arg0arg1...callback # as you realized, kebab-case will be converted to camelCase # and as you expect, if a named function is called ('./a::b'), that name (b) is used # if thats not enough, you can specify a custom name: forkpimp obj'tallFunc''./heavy-func' # will create obj.tallFunc
The following definitely doesn't make sense!
I had the use case to require a js or coffee file which exports a config and changed over time. I wanted to require the new file but got the same instance as before. The result was cached by nodes module system.
With fork-func you could do it easily in a child process to get a fresh config ;-)
But, as i noticed later, you better can do delete require.cache[path]
!!!
So, for me the sync variant is definitely useless.
sync
= require path cfg = forksync getCfgpath # path must be absolute!!!
(I will keep the sync method, only for remembering me not to implement senseless stuff caused by not knowing the api ;-) )
P.S.: fork-func tries to capture errors by either serializing the name
, message
and stack
of a child process error
or delegating an ipc error or one, witch is thrown on child process creation.
Enjoy!
License
fork-func is free and unencumbered public domain software. For more information, see http://unlicense.org/ or the accompanying UNLICENSE file.