| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162 |
- // const event = require('myevents');
- //
- //
- // let taskList_proxy = new Proxy({}, {
- // set: function(target, key, value, receiver) {
- // let bol = Reflect.set(target, key, value, receiver);
- // event.emit('task_num_change');
- // return bol;
- // },
- // deleteProperty: function(target, propKey) {
- // let bol = Reflect.deleteProperty(target, propKey);
- // event.emit('task_num_change');
- // return bol;
- // }
- // });
- //
- // module.exports = {
- // downloadingTasks: taskList_proxy,
- // stopDownloadTasks: {},
- // };
- const event = require('myevents');
- let taskList = {},
- QUEUE_STATUS = true //全局任务状态 , 0 可以进行下一个任务;
- module.exports = {
- add: function (task) {
- if (taskList[task._id]) {
- return false;
- }
-
- taskList[task._id] = task;
- return true;
- },
- remove: function (_id) {
- taskList[_id] = null;
- delete taskList[_id];
- },
- clear: function name(params) {
- taskList = {};
- },
- find: function (_id) {
- return taskList[_id];
- },
- list: function () {
- return taskList;
- },
- stopAll: function () {
- QUEUE_STATUS = false;
- },
- startAll: function () {
- QUEUE_STATUS = true;
- },
- get queue_status() {
- return QUEUE_STATUS;
- },
- get taskNum() {
- return Object.keys(taskList).length;
- }
- };
|