nthread-js

Nthread JS

Create easily threads in NodeJs. The purpose is to delegate some part of your code in own processus.
It means that the code is executed in another process, thread, and give you the possibility to communicate with the main process.

⚠ Be careful ⚠
Don't try to make an infinite loop during the creation of the thread.
Obviously, your server/computer will be affected by the number of threads.

☁️ Installation

$ npm install nthread-js

⚙️ Examples

const { listen } = require('nthread-js');

console.log("[root] - Run listen");

listen(3000, { debug: false })
  .then(async nthread => {
    console.log("[root] - Server connected");
    console.log("[root] - public uri", nthread.getPublicUri());
    console.log("[root] - local uri", nthread.getLocalUri());

    nthread.response(data => {
      console.log('[root] - message read from nthread : "', data.content, '" by "', data.guuid, '"');
      nthread.getByGuuid(data.guuid).send("Welcome from root =)");
    });

    // ---
    const child = await nthread.create(thread => {
      thread.log('[child] - Child is now connected with PID: ' + thread.getPid());

      thread.response(content => {
        thread.log('[child] - message read from thread : "', content, '"');
      });

      thread.send("Hello I'm Child =)");
    });
    
    child.response(content => {
      console.log('[root] - message read from child : "', content, '"');
    });
    // ---

    nthread.getByGuuid(child.getGuuid()).send("Hey Child, how are you?");

    // nthread.close();
  });

More examples

📝 Usage listen(string: port, object: options = undefined)

Options

Name	Type	Description
tmpFolder = '%default_tmp_folder%/nthread_generated'	String	Temporary folder used to save js code
secure = false	Boolean	Use protocol http or https
debug = false	Boolean	Enable debug
socket = undefined	Object	Socket.IO API
server = undefined	Object	http API https API

Functions from Nthread

Nthread is the return of listen function, to create new threads and manage them.

Name	Return	Description
getPublicUri()	String	Retrieve public uri
getLocalUri()	String	Retrieve local uri
getByGuuid()	Object: CThread	Retrieve CThread by Guuid
send(any: content)	Undefined	Send a message to all threads
response(function: callback)	Promise: any	Call back for each response from any threads
createFromIO(object: Socket.Io Client)	Promise: CThread	Create a new thread from Socket.Io Client
create(code: string)	Promise: CThread	Create a new thread from a lambda
load(string: file_path)	Promise: CThread	Create a new thread from a file with a lambda inside
close()	Undefined	Close every connection of each thread

Functions from CThread

CThread is the return after the promise of create/createFromIO/load function, to create new threads and manage the current thread from main thread.

Name	Return	Description
getPid()	Number	Retrieve pid of the thread
getGuuid()	String	Retrieve Guuid of CThread
send(any: content)	Undefined	Send a message to the current thread
response(function: callback)	Promise: any	Call back response from the current thread
on(string: instruction)	Undefined	Retrieve evenements sent by thread process (stdout, stderr, disconnect)
close()	Undefined	Close the connection of the current thread

Functions from the parameter thread in create/createFromIO/load callback

thread is the first parameter of the create/createFromIO/load callback, the code inside is running in another process, the thread.

Name	Return	Description
getPid()	Number	Retrieve pid of the thread
getGuuid()	String	Retrieve Guuid of CThread
log()	Undefined	Log a message directly in the main thread
send(any: content)	Undefined	Send a message to the main thread
response(function: callback)	Promise: any	Call back response from the thread
on(string: instruction)	Undefined	Retrieve evenements sent by thread process (disconnect)
close()	Undefined	Close the connection of the thread

📝 Usage connect(string: uri, object: options = undefined)

Options

Name	Type	Description
guuid = null	String	Set a nthread-js guuid
debug = false	Boolean	Enable debug
socket = undefined	Object	Socket.IO API
unctions from CThread

CThread is the return after the promise of connect function, to manage the thread and communicate with the main thread.

Name	Return	Description
getPid()	Number	Retrieve pid of the thread
getGuuid()	String	Retrieve Guuid of CThread
log()	Undefined	Log a message directly in the main thread
send(any: content)	Undefined	Send a message to the main thread
response(function: callback)	Promise: any	Call back response from the thread
on(string: instruction)	Undefined	Retrieve evenements sent by thread process (disconnect)
close()	Undefined	Close the connection of the thread