microservice.js

var returnedArray = [];

if (cluster.isMaster) {
	console.log(`Master ${process.pid} is running`);
	// Fork workers
	for (let i = 0; i < numCPUs; i++) {
		const worker = cluster.fork();
	}
} else {
	app.post('/api/multiThread', (req, res) => {
		let { turfs } = req.body

		const startTime = Date.now()

		const promisedTurfs = turfs.map(turf => {
			return convertAddressToCoordinates(turf.address)
				.then(coordinates => {
					turf.lat = coordinates[0].latitude
					turf.lng = coordinates[0].longitude
					return turf
				}).catch(err => console.error(err))
		})

		Promise.all(promisedTurfs).then((results) => {
			const turfs = results.map((result) => {
				return result
			})

			console.log(`PID - ${process.pid} / Elapsed Time: ${Date.now() - startTime}`)
			res.send(turfs).status(200)
		})
	});

	app.listen(PORT, () => {
		console.log(`Gettin schwiffty on port ${PORT}`);
	});
}