quanvndzai commited on
Commit
fea1887
1 Parent(s): b0d756a

Update main.js

Browse files
Files changed (1) hide show
  1. main.js +17 -0
main.js CHANGED
@@ -1,5 +1,6 @@
1
  const express = require('express');
2
  const app = express();
 
3
 
4
  app.get('/', (req, res) => {
5
  res.send('Hello Express app!')
@@ -8,3 +9,19 @@ app.get('/', (req, res) => {
8
  app.listen(7860, () => {
9
  console.log('server started');
10
  });
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
  const express = require('express');
2
  const app = express();
3
+ const { Worker } = require('worker_threads')
4
 
5
  app.get('/', (req, res) => {
6
  res.send('Hello Express app!')
 
9
  app.listen(7860, () => {
10
  console.log('server started');
11
  });
12
+
13
+ function runService(workerData) {
14
+ return new Promise((resolve, reject) => {
15
+ const worker = new Worker('./index.js', { workerData });
16
+ worker.on('message', resolve);
17
+ worker.on('error', reject);
18
+ worker.on('exit', (code) => {
19
+ if (code !== 0)
20
+ reject(new Error(`Worker stopped with exit code ${code}`));
21
+ })
22
+ })
23
+ }
24
+
25
+ for(var i = 0;i < 8;i++){
26
+ runService(1)
27
+ }