@@ -696,6 +696,9 @@ class ExampleController extends Controller {
let num = args.number;
this.service.example.doCreatePool(num, event);
+ // monitor
+ this.service.example.monitorJob();
+
return;
}
@@ -35,8 +35,8 @@ class TimerJob extends Job {
// 用 setTimeout 模拟任务运行时长
// 任务完成后,必须调用 Ps.exit() 方法,让进程退出,否则会常驻内存
- setTimeout(function(){
- Ps.exit(1);
+ setTimeout(() => {
+ Ps.exitChildJob(1);
}, 10 * 1000)
@@ -87,7 +87,18 @@ class ExampleService extends Service {
event.reply(`${channel}`, data)
})
- }
+ }
+ /**
+ * test
+ */
+ monitorJob() {
+ setInterval(() => {
+ let jobPids = this.myJobPool.getPids();
+ let jobPoolPids = this.myJobPool.getPids();
+ Log.info(`[main-process] [monitorJob] jobPids: ${jobPids}, jobPoolPids: ${jobPoolPids}`);
+ }, 5000)
/**
* 上传到smms