# centralized

**Repository Path**: mirrors_WebReflection/centralized

## Basic Information

- **Project Name**: centralized
- **Description**: A module to delegate to the main thread tasks meant to run for all forked threads
- **Primary Language**: Unknown
- **License**: ISC
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2022-02-20
- **Last Updated**: 2026-01-03

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# centralized

[![build status](https://github.com/WebReflection/centralized/actions/workflows/node.js.yml/badge.svg)](https://github.com/WebReflection/centralized/actions) [![Coverage Status](https://coveralls.io/repos/github/WebReflection/centralized/badge.svg?branch=main)](https://coveralls.io/github/WebReflection/centralized?branch=main)

<sup>**Social Media Photo by [Alex wong](https://unsplash.com/@killerfvith) on [Unsplash](https://unsplash.com/)**</sup>

A module to delegate to the main thread tasks meant to run for all forked threads.

```js
import cluster from 'node:cluster';
import {cpus} from 'node:os';

import centralized from 'centralized';

const appHelper = centralized({
  // properties can have any value
  connection: null,

  // methods can be used seamlessly from worker ot main
  query: async function(sql, ...values) {
    const stmt = this.connection.prepare(sql);
    return await stmt.exec(...values);
  },

  // the init method executes once only in the main thread ...
  init() {
    // ... and it can pollute its context with values
    this.connection = db.connect({user, pass, stuff});
  }
});

if (cluster.isWorker) {
  // this will return the result from the db
  const result = await appHelper.query(
    'SELECT * FROM table WHERE thing = ?',
    'cool'
  );
  console.log(result);
}
else {
  // perform the query all over the place
  for (let {length} = cpus(), i = 0; i < length; i++)
    cluster.fork();
}
```

And that's all folks 🥳