关于并发的数据请求！请问这样可以吗？

违规昵称_13518

新手入门，各位高手请指点！

1. //串行读取
   
2. var datas = [];
   
3. var model = api.require('model');
   
4. var query = api.require('query');
   
5. //读取一
   
6. query.createQuery(function (ret, err) {
   
7.     if (ret && ret.qid) {
   
8.         var qid = ret.qid;
   
9.         query.whereEqual({
   
10.             qid: qid,
    
11.             column: 'name',
    
12.             value: 'jack'
    
13.         });
    
14.         model.findAll({
    
15.             class: "user",
    
16.             qid: qid
    
17.         }, function (ret, err) {
    
18.             datas.push(ret);
    
19.             //读取二
    
20.             query.createQuery(function (ret, err) {
    
21.                 if (ret && ret.qid) {
    
22.                     var qid = ret.qid;
    
23.                     query.whereEqual({
    
24.                         qid: qid,
    
25.                         column: 'name',
    
26.                         value: 'anni'
    
27.                     });
    
28.                     model.findAll({
    
29.                         class: "user",
    
30.                         qid: qid
    
31.                     }, function (ret, err) {
    
32.                         datas.push(ret);
    
33.                         //读取三
    
34.                         query.createQuery(function (ret, err) {
    
35.                             if (ret && ret.qid) {
    
36.                                 var qid = ret.qid;
    
37.                                 query.whereEqual({
    
38.                                     qid: qid,
    
39.                                     column: 'name',
    
40.                                     value: 'cate'
    
41.                                 });
    
42.                                 model.findAll({
    
43.                                     class: "user",
    
44.                                     qid: qid
    
45.                                 }, function (ret, err) {
    
46.                                     datas.push(ret);
    
47.                                     //doSomethings
    
48.                                     console.log(datas.length);
    
49.                                 });
    
50.                             }
    
51.                         });
    
52.                     });
    
53.                 }
    
54.             });
    
55.         });
    
56.     }
    
57. });

复制代码

1. //并行读取
   
2. var datas = [];
   
3. //全部数据读取完毕
   
4. function finalLoaderComplete(){
   
5.     //doSomething
   
6.     console.log(datas.length);
   
7. }
   
8. 
   
9. var num = 3;
   
10. //一个数据读取完毕
    
11. function loaderComplete(data){
    
12.     datas.push(data);
    
13.     if (--num == 0) {
    
14.         finalLoaderComplete();
    
15.     };
    
16. }
    
17. 
    
18. var model = api.require('model');
    
19. var query = api.require('query');
    
20. //读取一
    
21. query.createQuery(function (ret, err) {
    
22.     if (ret && ret.qid) {
    
23.         var qid = ret.qid;
    
24.         query.whereEqual({
    
25.             qid: qid,
    
26.             column: 'name',
    
27.             value: 'jack'
    
28.         });
    
29.         model.findAll({
    
30.             class: "user",
    
31.             qid: qid
    
32.         }, function (ret, err) {
    
33.             loaderComplete(ret);
    
34.         });
    
35.     }
    
36. });
    
37. //读取二
    
38. query.createQuery(function (ret, err) {
    
39.     if (ret && ret.qid) {
    
40.         var qid = ret.qid;
    
41.         query.whereEqual({
    
42.             qid: qid,
    
43.             column: 'name',
    
44.             value: 'anni'
    
45.         });
    
46.         model.findAll({
    
47.             class: "user",
    
48.             qid: qid
    
49.         }, function (ret, err) {
    
50.             loaderComplete(ret);
    
51.         });
    
52.     }
    
53. });
    
54. //读取三
    
55. query.createQuery(function (ret, err) {
    
56.     if (ret && ret.qid) {
    
57.         var qid = ret.qid;
    
58.         query.whereEqual({
    
59.             qid: qid,
    
60.             column: 'name',
    
61.             value: 'cate'
    
62.         });
    
63.         model.findAll({
    
64.             class: "user",
    
65.             qid: qid
    
66.         }, function (ret, err) {
    
67.             loaderComplete(ret);
    
68.         });
    
69.     }
    
70. });

复制代码

代码示例：

test.zip 下载附件

2015-2-23 13:53上传708 Bytes下载次数: 897

2015-2-23 13:53 上传

点击文件名下载附件

技术支持-Altair

可以并行读取数据