Refactor examples

Author: tshemsedinov

README.md

@@ -11,7 +11,7 @@
 
 Запускаем 'node multicore', который подгружает сначала `master.js` и происходит
 порождение дочерних процессов по количеству ядер процессора
-`api.os.cpus().length` при помощи `api.cluster.fork()`, ссылки на воркеры
+`os.cpus().length` при помощи `cluster.fork()`, ссылки на воркеры
 складываются в массив `workers`. Родительский процесс рассылает дочерним через
 `worker.send()` задачу на исполнение. Дочерний процесс ловит задачу (это
 массив) и перемножает все его элементы на 2, после чего отправляет результат

tcp/client.js

@@ -1,9 +1,8 @@
 'use strict';
 
-global.api = {};
-api.net = require('net');
+const net = require('net');
 
-const socket = new api.net.Socket();
+const socket = new net.Socket();
 
 let user;
 
@@ -14,7 +13,7 @@ socket.connect({
   socket.write('Hello from client');
   socket.on('data', (data) => {
     user = JSON.parse(data);
-    console.log('Data received (by client): ' + data);
-    console.log('Age of ' + user.name + ' is ' + user.age);
+    console.log(`Data received (by client): ${data}`);
+    console.log(`Age of ${user.name} is ${user.age}`);
   });
 });

tcp/server.js

@@ -1,11 +1,10 @@
 'use strict';
 
-global.api = {};
-api.net = require('net');
+const net = require('net');
 
 const user = { name: 'Marcus Aurelius', age: 1895 };
 
-const server = api.net.createServer((socket) => {
+const server = net.createServer((socket) => {
   console.log('Connected: ' + socket.localAddress);
   socket.write(JSON.stringify(user));
   socket.on('data', (data) => {

workers/master.js

@@ -1,12 +1,15 @@
 'use strict';
 
+const os = require('os');
+const cluster = require('cluster');
+
 module.exports = () => {
 
-  const cpuCount = api.os.cpus().length;
+  const cpuCount = os.cpus().length;
 
   const workers = [];
   for (let i = 0; i < cpuCount; i++) {
-    const worker = api.cluster.fork();
+    const worker = cluster.fork();
     workers.push(worker);
   }
 
@@ -24,8 +27,8 @@ module.exports = () => {
     worker.on('message', (message) => {
 
       console.log(
-        'message from worker ' + worker.process.pid + ': ' +
-        JSON.stringify(message)
+        'message from worker ' + worker.process.pid +
+        ': ' + JSON.stringify(message)
       );
       results.push(message.result);
 

workers/multicore.js

@@ -1,10 +1,8 @@
 'use strict';
 
-global.api = {};
-api.cluster = require('cluster');
-api.os = require('os');
+const cluster = require('cluster');
 
-if (api.cluster.isMaster) {
+if (cluster.isMaster) {
   require('./master.js')();
 } else {
   require('./worker.js')();

workers/worker.js

@@ -1,8 +1,13 @@
 'use strict';
 
+const cluster = require('cluster');
+
 module.exports = () => {
 
-  console.log('Hello from worker ' + process.pid + ' ' + api.cluster.worker.id);
+  console.log(
+    'Hello from worker ' + process.pid +
+    ' ' + cluster.worker.id
+  );
 
   const caltulations = item => item * 2;