learn-nodejs-mysql/n12_async.js at master · hello-qu/learn-nodejs-mysql · GitHub

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
var async = require('async');

/*
function fun1() {
    var i = 0
    setInterval(function () {
        console.log('aaa', ++i);
        if (i == 3) {
            clearInterval(this)
        }
    }, 1000)
}

function fun2() {
    var k = 0
    setInterval(function () {
        console.log('bbb', ++k);
        if (k == 3) {
            clearInterval(this)
        }
    }, 1000)
}
*/

// fun1();
// fun2();
// console.log('point')

/*
function exec() {
    async.waterfall([function (done) {
        var i = 0
        setInterval(function () {
            console.log('aaa', ++i);
            if (i == 3) {
                clearInterval(this);
                done(null, 'aa--end')
            }
        }, 1000)
    },

    function (pre,done) {
        var i = 0
        setInterval(function () {
            console.log('aaa', ++i);
            if (i == 3) {
                clearInterval(this);
                done(null, pre+'bb--end')
            }
        }, 1000)
    }],function(err,res){
        console.log(err);
        console.log(res);
    })
}
exec()
*/

function exec() {
    async.series({one:function (callback) {
        var i = 0
        setInterval(function () {
            console.log('aaa' + (++i));
            if (i == 4) {
                clearInterval(this);
                callback(null, 'done-aa')
            }
        }, 1000)
    }, two:function (callback) {
        var j = 0
        setInterval(function () {
            console.log('bbb' + (++j));
            if (j == 4) {
                clearInterval(this);
                callback(null, 'done-bb')
            }
        }, 1000)
    }},function(err,res){
         console.log(err);
        console.log(res);
    }
    )
}

exec()

/*
function exec() {
    async.series({
        one: function (callback) {
            var i = 0
            setInterval(function () {
                console.log('aaa' + (++i));
                if (i == 4) {
                    clearInterval(this);
                    callback(null, 'done-aa')
                }
            }, 1000)
        },
        two: function (callback) {
            var j = 0
            setInterval(function () {
                console.log('bbb' + (++j));
                if (j == 4) {
                    clearInterval(this);
                    callback(null, 'done-bb')
                }
            }, 1000)
        }
    },function(err,res){
        console.log(err);
        console.log(res);
    })
}

exec()
*/