NodeJS如何实现同步的方法示例
前言
众所周知，异步是得天独厚的特点和优势，但同时在程序中同步的需求（比如控制程序的执行顺序为：func1 -> func2 ->func3 ）也是很常见的。
下面这篇文章主要介绍了关于NodeJS实现同步的相关内容，NodeJS被打上了单线程、非阻塞、事件驱动…..等标签。 在单线程的情况下，是无法开启子线程的。经过了很久的研究，发现并没有thread函数！！！但是有时候，我们确实需要“多线程”处理事务。nodeJS有两个很基础的api：setTimeout和setInterval。这两个函数都能实现“异步”。 nodeJS的异步实现：nodeJS有一个任务队列，在使用setInterval函数的时候，会每隔特定的时间向该任务队列增加任务，从而实现“多任务”处理。但是，“特定的时间”不代表是具体的时间，也有可能是会大于我们设定的时间，也有可能小于。
我们跑跑下面代码块
setInterval(function() {
console.log(new Date().getTime());
}, 1000);
输出的结果如下：
1490531390640
1490531391654
1490531392660
1490531393665
1490531394670
1490531395670
1490531396672
1490531397675
......
我们可以看到，所有的时间间隔都是不一样的。时间的偏移不仅包含了间隔的1s，还包含了console.log()的耗时，以及new Date()的耗时。在大量的数据统计下，时间间隔近似于1s。
问题来了，setInterval是能实现多任务的效果，但是怎样才能实现任务之间的同步操作呢？
这里实现的方法是通过回调函数实现的。
function a(callback) {
// 模拟任务a耗时
setTimeout(function() {
console.log("task a end!");
// 回调任务b
callback();
}, 3000);
};
function b() {
setTimeout(function() {
console.log("task b end!");
}, 5000);
}
a(b);
这里举了一个很简单的例子，就是将b方法的实现赋值给a方法的callback函数从而实现函数回调，但是会有个问题。假设a方法依赖于b方法，b方法依赖于c方法，c方法依赖于d方法…..也就意味着每个方法的实现都需要持有上一个方法的实例，从而实现回调。
function a(b, c, d) {
console.log("hello a");
b(c, d);
};
function b(c, d) {
console.log("hello b");
c(d);
};
function c(d) {
console.log("hello c");
d()
};
function d() {
console.log("hello d");
};
a(b, c, d);
输出结果
hello a
hello b
hello c
hello d
如果回调函数写的多了，会造成代码特别特别恶心。
如果有类似于sync的函数能让任务顺序执行就更好了。终于找到了async这个库 $ npm instanll async
async = require("async");
a = function (callback) {
// 延迟5s模拟耗时操作
setTimeout(function () {
console.log("hello world a");
// 回调给下一个函数
callback(null, "function a");
}, 5000);
};
b = function (callback) {
// 延迟1s模拟耗时操作
setTimeout(function () {
console.log("hello world b");
// 回调给下一个函数
callback(null, "function b");
}, 1000);
};
c = function (callback) {
console.log("hello world c");
// 回调给下一个函数
callback(null, "function c");
};
// 根据b, a, c这样的顺序执行
async.series([b, a, c], function (error, result) {
console.log(result);
});
注释基本能够很好的理解了，我们看看输出
hello world b
hello world a
hello world c
[ 'function b', 'function a', 'function c' ]
上面的基本async模块的实现的如果了解更多关于async模块的使用，可以点击：查看详情
其实nodeJS基本api也提供了异步实现同步的方式。基于Promise+then的实现
sleep = function (time) {
return new Promise(function () {
setTimeout(function () {
console.log("end!");
}, time);
});
};
console.log(sleep(3000));
输出结果为:
Promise { <pending> }
end!
可以看出来，这里返回了Promise对象，直接输出Promise对象的时候，会输出该对象的状态，只有三种：PENDING、FULFILLED、REJECTED。字面意思很好理解。也就是说Promise有可能能实现我们异步任务同步执行的功能。我们先用Promise+then结合起来实现异步任务同步操作。
sleep = function () {
return new Promise(function (resolve, reject) {
setTimeout(function () {
console.log("start!");
resolve();
}, 1000);
})
.then(function () {
setTimeout(function () {
console.log("end!");
}, 2000);
})
.then(function () {
console.log("end!!");
})
};
console.log(sleep(1000));
输出结果：
Promise { <pending> }
start!
end!!
end!
在new Promise任务执行完后，调用了resolve才会执行所有的then函数，并且这些then函数是异步执行的。由输出结果可以知道。（如果所有then是顺序执行的应该是end! -> end!!）。但是上述也做到了两个异步任务之间顺序执行了。
不过，还有更加优雅的方式：使用async+await。
display = function(time, string) {
return new Promise(function (resovle, reject) {
setTimeout(function () {
console.log(string);
resovle();
}, time)
});
};
// 执行顺序：b a c
fn = async function () {
// 会造成阻塞
await display(5000, "b");
await display(3000, "a");
await display(5000, "c");
}();
输出结果：
b
a
c
由于这里时间输出比较尴尬，只能通过我们来感知，本人通过个人“感知”知道了在display b过度到display a的时候大概用了3s，再过度到display c的时候大概用了5s
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对我们的支持。
相关推荐
-
node.js将MongoDB数据同步到MySQL的步骤
前言 最近由于业务需要,APP端后台需要将MongoDB中的数据同步到Java端后台的MySQL中,然后又将MySQL中算好的数据,同步到MongoDB数据库. 这个过程看是很繁琐,实际上这就是一个互相写表的过程. 接下来就看看node.js将MongoDB中的数据批量插入到MySQL数据库的实现过程.话不多说了,来一起看看详细的介绍吧. 环境 node.js MongoDB MySQL npm 需要的模块 mongoose MySQL 准备好MongoDB中的数据 比如说:我这里要同步的是用户
-
node.js中实现同步操作的3种实现方法
众所周知,异步是得天独厚的特点和优势,但同时在程序中同步的需求(比如控制程序的执行顺序为:func1 -> func2 ->func3 )也是很常见的.本文就是对这个问题记录自己的一些想法. 需要执行的函数: 复制代码 代码如下: var func1 = function(req,res,callback){ setTimeout(function(){ console.log('in func1'); callback(req,res,1); },13000); }
-
node koa2实现上传图片并且同步上传到七牛云存储
因为升级到新的node版本,之前的通过很多上传图片的方式都已经不适用了,所以自己就写了一个对于 koa2上传图片的小demo,记录一下心得. 废话不多说,下面直接上代码,里面都有注释. const Koa = require('koa'); const route = require('koa-route'); const serve = require('koa-static'); const inspect = require('util').inspect const path = req
-
node.js 利用流实现读写同步,边读边写的方法
如下所示: //10个数 10个字节,每次读4b,写1b let fs=require("fs"); function pipe(source,target) { //先创建可读流,再创建可写流 //先读一次,rs.on(data) //将读到的类容写入目标中 ,返回布尔值,如果是ture,继续写,默认情况应该是false,暂停读取 //ws.on('drain'),抽干后,回复读取 //监听读取文件完毕后,关闭读取rs.on('end') let rs=fs.createReadSt
-
Node.js 使用流实现读写同步边读边写功能
废话不多说了,直接给大家贴代码了,具体代码如下所示: //10个数 10个字节,每次读4b,写1b let fs=require("fs"); function pipe(source,target) { //先创建可读流,再创建可写流 //先读一次,rs.on(data) //将读到的类容写入目标中 ,返回布尔值,如果是ture,继续写,默认情况应该是false,暂停读取 //ws.on('drain'),抽干后,回复读取 //监听读取文件完毕后,关闭读取rs.on('end') l
-
node.js中的forEach()是同步还是异步呢
node里几乎所有用到回调函数的地方,都是异步的,回调函数后面的代码很可能比回调函数中的代码后先执行,特别是数据库操作.当然,node也提供了同步版本的函数,例如文件操作,fs.readFileSync()是fs.readFile()的同步版本. 那么问题来了,forEach()是不是异步的呢?按理说,没有加Sync,应该是异步的呀. 复制代码 代码如下: var arr = ['a', 'b', 'c']; var str = '123'; arr.forEach(function(ite
-
我的Node.js学习之路（三）--node.js作用、回调、同步和异步代码 以及事件循环
一,node.js的作用, I/O的意义,(I/O是输入/输出的简写,如:键盘敲入文本,输入,屏幕上看到文本显示输出.鼠标移动,在屏幕上看到鼠标的移动.终端的输入,和看到的输出.等等) node.js想解决的问题,(处理输入,输入,高并发 .如 在线游戏中可能会有上百万个游戏者,则有上百万的输入等等)(node.js适合的范畴:当应用程序需要在网络上发送和接收数据时Node.js最为适合.这可能是第三方的API,联网设备或者浏览器与服务器之间的实时通信) 并发的意义,(并发这个术语描述的
-
NodeJS如何实现同步的方法示例
前言 众所周知,异步是得天独厚的特点和优势,但同时在程序中同步的需求(比如控制程序的执行顺序为:func1 -> func2 ->func3 )也是很常见的. 下面这篇文章主要介绍了关于NodeJS实现同步的相关内容,NodeJS被打上了单线程.非阻塞.事件驱动-..等标签. 在单线程的情况下,是无法开启子线程的.经过了很久的研究,发现并没有thread函数!!!但是有时候,我们确实需要"多线程"处理事务.nodeJS有两个很基础的api:setTimeout和setInt
-
C#多线程编程之使用ReaderWriterLock类实现多用户读与单用户写同步的方法
本文实例讲述了C#多线程编程之使用ReaderWriterLock类实现多用户读与单用户写同步的方法.分享给大家供大家参考,具体如下: 摘要:C#提供了System.Threading.ReaderWriterLock类以适应多用户读/单用户写的场景.该类可实现以下功能:如果资源未被写操作锁定,那么任何线程都可对该资源进行读操作锁定,并且对读操作锁数量没有限制,即多个线程可同时对该资源进行读操作锁定,以读取数据. 使用Monitor或Mutex进行同步控制的问题:由于独占访问模型不允许任何形式的
-
C#应用BindingSource实现数据同步的方法
本文以实例形式讲述了C#应用BindingSource实现数据同步的方法,对C#数据库程序开发来说具有一定的参考借鉴价值.具体实现方法如下: 下面的代码示例演示如何使用 BindingSource 组件,将三个控件(两个文本框控件和一个 DataGridView 控件)绑定到 DataSet 中的同一列. 该示例演示如何处理 BindingComplete 事件,并确保当一个文本框的文本值更改时,会用正确的值更新其他文本框和 DataGridView 控件. 具体代码如下: // Declare
-
Java线程同步Lock同步锁代码示例
java线程同步原理 java会为每个object对象分配一个monitor,当某个对象的同步方法(synchronizedmethods)被多个线程调用时,该对象的monitor将负责处理这些访问的并发独占要求. 当一个线程调用一个对象的同步方法时,JVM会检查该对象的monitor.如果monitor没有被占用,那么这个线程就得到了monitor的占有权,可以继续执行该对象的同步方法:如果monitor被其他线程所占用,那么该线程将被挂起,直到monitor被释放. 当线程退出同步方法调用时
-
Node.js实现mysql连接池使用事务自动回收连接的方法示例
本文实例讲述了Node.js实现mysql连接池使用事务自动回收连接的方法.分享给大家供大家参考,具体如下: var mysql = require('mysql'), Connection = require('mysql/lib/Connection.js'); var pool = mysql.createPool({ host: '127.0.0.1', database: 'myDB', port: 3306, user: 'root', password: 'root', debug
-
使用react实现手机号的数据同步显示功能的示例代码
本文介绍了使用react实现手机号的数据同步显示功能的示例代码,分享给大家,具体如下: 要求如下 输入框输入内容数据长度大于0,展示出预览信息 光标离开关闭预览信息 预览信息每隔4位插入一个特殊字符_,输入内容不变 限制长度为13位 只允许输入数字(0-9) // Zinput.js import React, { Component } from 'react'; import './Zinput.css' // NOTE: 获取焦点事件 原生onFocus 即可 // NOTE: 离开焦点事
-
node.js遍历目录的方法示例
本文介绍了node.js遍历目录的方法示例,分享给大家,也给自己留个笔记,具体如下 同步遍历 const fs = require('fs'); const path=require('path'); function travel(dir,callback){ fs.readdirSync(dir).forEach((file)=>{ var pathname=path.join(dir,file) if(fs.statSync(pathname).isDirectory()){ travel
-
Angular异步变同步处理方法
1. 背景 在前端项目中,经常会遇到页面有多个接口,后一个接口参数需要从前一个接口的返回数据中获取,这就存在接口必须按顺序一个一个执行.而Angular提供的Http服务请求接口都是异步请求,因此通常情况下会写成如下的代码: funA(arg1,arg2,function(){ funcB(arg1,arg2,function(){ funcC(arg1,arg2,function(){ xxxx.... }) }) }); 这不仅造成页面代码混乱不易维护,也让开发者无法追踪代码的运行.本身嵌套
-
android调用C语言实现内存的读取与修改的方法示例
写之前需要准备以下内容 android studio 已ROOT安卓设备 GG修改器 打开android studio,创建Native C++ Project activity_main.xml <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" andro
-
Vue自动构建发布脚本的方法示例
简介 使用cross-env, scp2两个插件完成 cross-env cross-env这是一款运行跨平台设置和使用环境变量的脚本. 为什么需要cross-env? NODE_ENV=production 像这样设置环境变量时,大多数Windows命令提示符都会阻塞 .(Windows上的Bash是例外,它使用本机Bash.)同样,Windows和POSIX命令使用环境变量的方式也有所不同.对于POSIX,您可以使用: $ENV_VAR 和在Windows上可以使用 %ENV_VAR% .