-
Notifications
You must be signed in to change notification settings - Fork 0
/
test.js
64 lines (52 loc) · 1.19 KB
/
test.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
const nodeq = require('./index.js')
const Node = require('./Node.js')
const util = require('util')
let Queue = new nodeq.Q()
let Worker = new nodeq.Worker()
function success() {
return new Promise((resolve, reject) => {
setTimeout(() => {
console.log({name: 'successful job', res: 'result'})
resolve()
}, 2000)
})
}
function bad() {
return new Promise((resolve, reject) => {
setTimeout(() => {
console.log({name: 'bad job', res: 'result'})
reject('job error')
}, 2000)
})
}
Queue.addJob(success, 1)
Queue.addJob(bad, 2)
Queue.addJob(success, 3)
// Queue.run((err, done) => {
// if(done) {
// console.log('finished all')
// }
// })
Worker.define('test_worker', {
jobs: Queue,
every: '* * * * *'
})
Worker.start((err, res, done) => {
if(done) {
console('all jobs done, waiting until next event')
}
})
Worker.on('test_worker:done', function(err, res) {
if(err) {
console.log('done error -> ' + err)
} else {
console.log('event for test_worker')
console.log(res)
}
})
// Queue.display()
// Queue.run()
// console.log(Worker)
// setInterval(function() {
// console.log(util.format("Memory usage: %dMB", ((process.memoryUsage().rss / 1024) / 1024).toFixed(1)));
// }, 5000)