Infrastructure/ghost
0
Fork 0
mirror of https://github.com/TryGhost/Ghost.git synced 2025-04-15 03:01:37 -05:00
Code Issues Activity

Added description for job termination best practice

Browse source
This commit is contained in:
Naz 2020-11-25 13:55:34 +13:00
parent c3ab2be076
commit d94830071d
1 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
ghost/job-manager/test/jobs/graceful.js
View file

@ -1,12 +1,12 @@
/* eslint-disable no-console */
const setTimeoutPromise = require('util').promisify(setTimeout);
const threads = require('bthreads');
const {isMainThread, parentPort} = require('bthreads');
let shutdown = false;
if (!threads.isMainThread) {
threads.parentPort.on('message', (message) => {
if (!isMainThread) {
parentPort.on('message', (message) => {
console.log(`paret message received: ${message}`);
if (message === 'cancel') {
shutdown = true;
@ -26,7 +26,15 @@ if (!threads.isMainThread) {
await setTimeoutPromise(100); // async cleanup imitation
process.exit(0);
if (parentPort) {
// preferred method of shutting down the worker
// it signals job manager about finished job and the thread
// is later terminated through `terminate()` method allowing
// for unfinished pipes to flush (e.g. loggers)
parentPort.postMessage('done');
} else {
process.exit(0);
}
}
}
})();