Nodejs中怎么实现函数的串行执行

nodejs实现函数串行执行

众所周知，nodejs是用非阻塞异步io机制，也就是说函数执行完成的先后顺序和代码的编写的先后顺序可能不同，实际的顺序取决于一个函数自身执行的快慢。这就出现一个在nodejs中怎么编写串行执行也就是顺序执行代码的问题。试想，要是你写了2个函数，一个查询数据库，另一个返回查询的结果，要是不用串行执行那么还没等数据库查询完毕就返回了结果，这显然是不行的。因而串行执行在nodejs中很有用。那么怎么实现呢？

大家可能会说，将返回查询结果的函数写在查询数据库函数的回调函数里面就好了呀，但是有过开发经验的朋友一定知道，要是情况比较复杂时就会产生一个回调地狱的问题，即层层嵌套，最后都不知道自己写了些什么，可读性和维护性很差。

我们不防换个思路，要是将这些想要顺序执行的函数放到一个数组里面，当一个函数执行完毕时在执行数组里面的下一个函数不就行了嘛。其实，nodejs开源社区中的很多串行模块的基本思想就是这个。接下来我们一步一步完成这个串行的demo：

1.首先我们定义一个保存函数执行顺序的数值：

var tasks = [];

2.再定义一个往数值里面加入串行化执行函数的函数：

function addTask(task){
     tasks.push(task);
}

3.执行数组中下一个函数的函数：

function next(){
     if(tasks.length > 0){
        tasks.shift()();
     }else{
       return;
     }
}

ok,大功告成，接下来定义几个测试函数：

var task1 = function(){
     console.log('task1 is finished');
     next();
}
var task2 = function(){
     console.log('task2 is finished');
     next();}var task3 = function(){
     console.log('task3 is finished');
     next();
}

开始测试：

addTask(task1);
addTask(task2);
addTask(task3);
next()

换个顺序：

addTask(task1);
addTask(task3);
addTask(task2);
next();

ok,大功告成。基于这个思想，在实际开发中大家可以定义一个模块，将这个串行打包，再也不用害怕回调地狱问题啦。

还可以用第三方库，如async.

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我们的支持。如果你想了解更多相关内容请查看下面相关链接

赞 (0)

相关推荐

  • nodejs使用async模块同步执行的方法

    nodejs使用async模块同步执行的方法

    首先安装 模块async 测试代码: call.js exports.fun1 = function (callback) { setTimeout(function(){ console.log('方法1'); callback('1'); },1900); } exports.fun2 = function (callback) { setTimeout(function(){ console.log('方法2'); callback('2'); },1700); } exports.fun

  • NodeJS实现同步的方法

    NodeJS被打上了单线程.非阻塞.事件驱动-..等标签. 在单线程的情况下,是无法开启子线程的.经过了很久的研究,发现并没有thread函数!!!但是有时候,我们确实需要"多线程"处理事务.nodeJS有两个很基础的api:setTimeout和setInterval.这两个函数都能实现"异步". nodeJS的异步实现:nodeJS有一个任务队列,在使用setInterval函数的时候,会每隔特定的时间向该任务队列增加任务,从而实现"多任务"

  • Node.js npm命令运行node.js脚本的方法

    //通过npm运行node脚本 (控制台应用程序) cmd---cd package.json所在的目录---npm start (package.json中的scripts属性中设置start命令) cmd---npm (通过该命令可以查看npm后面能够设置的具体命令) package.json: { "scripts":{ "start": "node demo.js", // cmd环境中,npm start命令 就相当于 node dem

  • nodejs npm错误Error:UNKNOWN:unknown error,mkdir 'D:\Develop\nodejs\node_global'at Error

    nodejs npm错误Error:UNKNOWN:unknown error,mkdir 'D:\Develop\nodejs\node_global'at Error

    错误原因 在设置npm的cache和predix时,因为使用参考其他教程照抄,而没有修改为本机对应路径,本机上并没有这个地址,因此造成了错误. 教程代码: npm config set cache "D:\Develop\nodejs\node_global" npm config set prefix "D:\Develop\nodejs\node_cache" 结果就是输入与npm任何有关的命令时,都会报错: 错误代码文本形式: Error: UNKNOWN:

  • ndm:NPM的桌面GUI应用程序

    ndm:NPM的桌面GUI应用程序

    如果你熟悉ruby的gem,Python的pypi.setuptools,PHP的pear,那么你就知道NPM的作用是什么了. NPM 是 Node Package Manager (node 包管理器)的缩写,它是用于安装 NodeJS 软件包或模块的命令行软件包管理器.我们发布过一个指南描述了如何使用 NPM 管理 NodeJS 包.你可能已经注意到,使用 Npm 管理 NodeJS 包或模块并不是什么大问题.但是,如果你不习惯用 CLI 的方式,这有一个名为 NDM 的桌面 GUI 程序,

  • nodejs同步调用获取mysql数据时遇到的大坑

    mysql调用获取数据,只能是异步方式返回结果,不能同步获取结果,因此,须在回调函数中编写处理事件.期间看了下Aysnc.js,是用于多个要返回回调函数的事件,将这些事件有序的组织起来,最后只返回一个回调函数,并没有改变异步的本质,而是将多个异步整合为一个异步,从而满足写程序的需求. 错误示范 获取数据库中的数据函数 var _getUser = function(name) { var sql = "SELECT * FROM " + TABLE + " WHERE use

  • 详解Vue项目在其他电脑npm run dev运行报错的解决方法

    详解Vue项目在其他电脑npm run dev运行报错的解决方法

    一个 Vue 项目从一台电脑上传到 github 上之后,再另外一台电脑上 git clone .并使用 npm run dev 或 npm run start 发生以下报错的解决方法. 报错原因 缺少 node_modules 里面的依赖.在项目目录下使用 npm install 然后再 npm run dev. 如果在这一步当中, npm install 执行的过程中,处于一直卡顿的状态.说明网络状况不佳.建议使用 cnpm 淘宝源. 淘宝源 使用 cnpm -v 查看是否已经安装 cnpm

  • Nodejs让异步变成同步的方法

    Nodejs让异步变成同步的方法

    异步给我们带来的性能是明显的,但同时也给我们带了复杂的业务逻辑过程,特别请求依赖多的时候,下面我们来看看如何解决此类这样的问题. 使用方法 在这里我们信赖于co这个库. npm install co --save #or yarn add co 模拟 # 登录请求 let loginReq = new Promise((resolve,reject)=>{ setTimeout(function () { resolve({success:true}) },2000) }); # 获取用户信息

  • 使用Dockerfile部署nodejs服务的方法步骤

    初始化Dockerfile 假设我们的项目名为express,在express项目中创建编辑Dockerfile文件: $ vim Dockerfile FROM node:latest RUN mkdir -p /home/www/express WORKDIR /home/www/express COPY . /home/www/express RUN npm install EXPOSE 3000 ENTRYPOINT ["npm", "run"] CMD [

  • Nodejs实现的操作MongoDB数据库功能完整示例

    本文实例讲述了Nodejs实现的操作MongoDB数据库功能.分享给大家供大家参考,具体如下: mongodb_demo.js /** cnpm install mongodb */ var MongoClient = require('mongodb').MongoClient; var DB_CONN_STR = 'mongodb://test:123456@127.0.0.1:27017/test'; // 数据库为 test var insertData = function (db,

随机推荐