Node.js编程之异步

var isTrue = function(value, callback) {
  if (value === true) {
    callback(null, "Value was true.");
  }
  else {
    callback(new Error("Value is not true!"));
  }
}

var callback = function (error, value) {
  if (error) {
    return console.log(error);
  }
  console.log(value);
}

function asyncFunction(callback) {
  setTimeout(callback, 200)  
}

var color = 'blue'

asyncFunction(function(){
  console.log('The color is ' + color)  // The color is green.(这个最后执行(200ms之后))
})

color = 'green'

function asyncFunction(callback) {
  setTimeout(callback, 200)  
}

var color = 'blue'

(function(color) {
  asyncFunction(function(){
    console.log('The color is ' + color)  // The color is blue.
  })
})(color);

color = 'green 

setTimeout(function(){
   console.log('I execute first.')
   setTimeout(function(){
      console.log('I execute next.')
      setTimeout(function(){
         console.log('I execute last.')
      }, 100)
   }, 500)
}, 1000)    

 promise.then(function(result){
        // dosomething
        return result;
    }).then(function(result) {
        // dosomething
        return promise1;   
    }).then(function(result) {
        // dosomething
    }).catch(function(ex) {
        console.log(ex);
    }).finally(function(){
        console.log("final");
    });

// 在一个简单的程序中实现串行化流程控制
var fs = require('fs')
var request = require('request') // 用它获取RSS数据
var htmlparser = require('htmlparser') // 把原始的RSS数据转换成JavaScript结构
var configFilename = './rss_feeds.txt'

function checkForRSSFile() { // 任务1：确保包含RSS预定源URL列表的文件存在
  fs.exists(configFilename, function(exists) {
    if (!exists) {
      return next(new Error('Missing RSS file: ' + configFilename)) // 只要有错误就尽早返回
    }
    next(null, configFilename)
  })
}

function readRSSFile (configFilename) { // 任务2：读取并解析包含预定源URL的文件
  fs.readFile(configFilename, function(err, feedList) {
    if (err) {
      return next(err)
    }

    feedList = feedList                          // 讲预定源URL列表转换成字符串，然后分隔成一个数组
                 .toString()
                 .replace(/^\s+|\s+$/g, '')
                 .split("\n");
    var random = Math.floor(Math.random()*feedList.length)  // 从预定源URL数组中随机选择一个预定源URL
    next(null, feedList[random])
  })
}
// console.log('进入')

function downloadRSSFeed(feedUrl) {  // 任务3：向选定的预定源发送HTTP请求以获取数据
  request({uri: feedUrl}, function(err, res, body) {
    if (err) {
      return next(err)
    }
    if (res.statusCode != 200) {
      return next(new Error('Abnormal response status code'))
    }

    next(null, body)
  })
}

function parseRSSFeed(rss) {  // 任务4：将预定源数据解析到一个条目数组中
  var handler = new htmlparser.RssHandler()
  var parser = new htmlparser.Parser(handler)
  parser.parseComplete(rss)
  if (!handler.dom.items.length) {
    return next(new Error('No RSS items found'))
  }
  console.log(handler.dom.items)
  var item = handler.dom.items.shift()
  console.log(item.title)
  console.log(item.link)
}
var tasks = [ checkForRSSFile,      // 把所有要做的任务按执行顺序添加到一个数组中
              readRSSFile,
              downloadRSSFeed,
              parseRSSFeed ]

function next(err, result) {
  if (err) {
    throw err
  }

  var currentTask = tasks.shift()   // 从任务数组中取出下个任务

  if (currentTask) {
    currentTask(result)   // 执行当前任务
  }
}

next()  // 开始任务的串行化执行

// 在一个简单的程序中实现并行流程控制
var fs = require('fs')
var completedTasks = 0
var tasks = []
var wordCounts = {}
var filesDir = './text'

function checkIfComplete() {   // 当所有任务全部完成后，列出文件中用到的每个单词以及用了多少次
  completedTasks++
  // console.log(completedTasks)
  console.log(tasks.length)
  if (completedTasks == tasks.length) {
    for(var index in wordCounts) {
      console.log(index + ': ' + wordCounts[index])
    }
  }
}

function countWordsInText(text) {
  var words = text
    .toString()
    .toLowerCase()
    .split(/\W+/)
    .sort()
  for (var index in words) {     // 对文本中出现的单词计数
    var word = words[index]
    if (word) {
      wordCounts[word] = (wordCounts[word]) ? wordCounts[word] + 1 : 1
    }
  }
}

fs.readdir(filesDir, function(err, files) {    // 得出text目录中的文件列表
  if (err) {
    throw err
  }
  for(var index in files) {
    var task = (function(file) {     // 定义处理每个文件的任务，每个任务中都会调用一个异步读取文件的函数并对文件中使用的单词计数
      return function() {
        fs.readFile(file, function(err, text) {   // 这里注意fs.readFile()是一个异步进程，countWordsInText(),checkIfComplete()方法会在tasks.push()方法后面进行
          if (err) {
            throw err
          }
          countWordsInText(text)
          checkIfComplete()
        })
      }
    })(filesDir + '/' + files[index])
    tasks.push(task)
  }
  for(var task in tasks) {
    tasks[task]()
  }
})