js的co.js源码解析

2024-03-27 21:58
文章标签 源码 js 解析 co

本文主要是介绍js的co.js源码解析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

co的主要思想是利用把每个yield后面的值转成一个Promise对象,然后给该Promise对应注册fulfilled和rejected两个回调,在这两个回调里会执行next函数,进行下一步迭代,也就是执行下一个yield,从而不断地向前驱动迭代器,直到执行完毕或者出错。

co的好处:

    var content = yield readSomethingAsync();console.log(content);

即使readSomethingAsync是异步完成的,但是当执行到console.log(content);这里的时候可以保证content的内容是我们想要的。而不需要通过在一大堆回调里对content进行赋值。这就是通过同步的方式写异步代码。
co的大致执行流程
这里写图片描述


/*** slice() reference.*/var slice = Array.prototype.slice;/*** Expose `co`.*/module.exports = co['default'] = co.co = co;/*** Wrap the given generator `fn` into a* function that returns a promise.* This is a separate function so that* every `co()` call doesn't create a new,* unnecessary closure.** @param {GeneratorFunction} fn* @return {Function}* @api public*/
// 包裹一个generatorFunction,后面执行
co.wrap = function (fn) {createPromise.__generatorFunction__ = fn;return createPromise;function createPromise() {// 执行generatorFunction,返回一个iterator供co使用return co.call(this, fn.apply(this, arguments));}
};/*** Execute the generator function or a generator* and return a promise.** @param {Function} fn* @return {Promise}* @api public*/
// 参数可以是生成器函数或者迭代器
function co(gen) {var ctx = this;// 获取传给生成器函数的参数,如果gen是迭代器则该参数没用,见下面的gen.apply(ctx, args);var args = slice.call(arguments, 1)// we wrap everything in a promise to avoid promise chaining,// which leads to memory leak errors.// see https://github.com/tj/co/issues/180return new Promise(function(resolve, reject) {/* gen是函数说明是一个生成器函数,此时,执行生成器函数返回一个迭代器如果gen不是一个函数,则一般情况下是一个迭代器,否则直接resovle该值返回*/if (typeof gen === 'function') gen = gen.apply(ctx, args);if (!gen || typeof gen.next !== 'function') return resolve(gen);// 迭代器开始自动执行onFulfilled();/*** @param {Mixed} res* @return {Promise}* @api private*/function onFulfilled(res) {var ret;try {// 执行到yield语句,返回yield语句右边的值,传入的res是上一个yield右边对应的Promise决议的值ret = gen.next(res);} catch (e) {// 出错则rejectreturn reject(e);}// 已yield返回值为参数,执行next,进行下一次的迭代next(ret);}/*** @param {Error} err* @return {Promise}* @api private*/function onRejected(err) {var ret;try {// 抛出异常,如果当前的yield在try中,则该异常由生成器内部捕获处理,否则由onRejected函数处理ret = gen.throw(err);} catch (e) {return reject(e);}next(ret);}/*** Get the next value in the generator,* return a promise.** @param {Object} ret* @return {Promise}* @api private*/function next(ret) {// 迭代器执行完毕则resolveif (ret.done) return resolve(ret.value);// 把yield返回的值,也就是迭代器返回的值转成Promisevar value = toPromise.call(ctx, ret.value);/*如果返回的值是一个Promise,或者能被转成Promise,则注册后续的回调,等待value(a Promise)的决议,resolve或者reject。这里是co库的重点,每一次yield后,返回的值都会被转成一个Promise,然后等待该Promise决议,执行注册的回调,在回调中继续调用next执行下一次迭代,也就是执行下一个yield,循环这个过程,直到迭代器结束。*/if (value && isPromise(value)) return value.then(onFulfilled, onRejected);// 不能转成Promise则抛出异常return onRejected(new TypeError('You may only yield a function, promise, generator, array, or object, '+ 'but the following object was passed: "' + String(ret.value) + '"'));}});
}/*** Convert a `yield`ed value into a promise.** @param {Mixed} obj* @return {Promise}* @api private*/
// 把obj转成Promise
function toPromise(obj) {if (!obj) return obj;if (isPromise(obj)) return obj;if (isGeneratorFunction(obj) || isGenerator(obj)) return co.call(this, obj);if ('function' == typeof obj) return thunkToPromise.call(this, obj);if (Array.isArray(obj)) return arrayToPromise.call(this, obj);if (isObject(obj)) return objectToPromise.call(this, obj);return obj;
}/*** Convert a thunk to a promise.** @param {Function}* @return {Promise}* @api private*/
/*把thunk函数转成Promise,thunk函数具体可参考thunkify库,实际是一个偏函数,最后一个参数需要一个回调,如下代码所示。
*/
function thunkToPromise(fn) {var ctx = this;return new Promise(function (resolve, reject) {/*fn是一个偏函数,里面包裹这一个异步函数,此时他还需要最后一个参数,也就是回调函数。如果不调用回调则该Promise无法决议。执行fn的时候,一般是一个异步的操作,比如readFile读取文件,然后读取完毕后会执行回调,在回调了执行该Promise的resolve或者reject*/fn.call(ctx, function (err, res) {if (err) return reject(err);if (arguments.length > 2) res = slice.call(arguments, 1);resolve(res);});});
}/*** Convert an array of "yieldables" to a promise.* Uses `Promise.all()` internally.** @param {Array} obj* @return {Promise}* @api private*/
// 数组转成Promise
function arrayToPromise(obj) {// 把数组里的每个元素都转成Promise,Promise.all等待该数组中的所有的Promise决议return Promise.all(obj.map(toPromise, this));
}/*** Convert an object of "yieldables" to a promise.* Uses `Promise.all()` internally.** @param {Object} obj* @return {Promise}* @api private*/function objectToPromise(obj){var results = new obj.constructor();var keys = Object.keys(obj);var promises = [];// 把对象中的每个值转成一个Promisefor (var i = 0; i < keys.length; i++) {var key = keys[i];// 把对象的值转成Promise,如果不能转,则直接记录该值var promise = toPromise.call(this, obj[key]);if (promise && isPromise(promise)) defer(promise, key);else results[key] = obj[key];}// 等待所有Promise的决议,然后返回resultsreturn Promise.all(promises).then(function () {return results;});// 往promises数组中加promisefunction defer(promise, key) {// predefine the key in the resultresults[key] = undefined;promises.push(promise.then(function (res) {results[key] = res;}));}
}/*** Check if `obj` is a promise.** @param {Object} obj* @return {Boolean}* @api private*/function isPromise(obj) {return 'function' == typeof obj.then;
}/*** Check if `obj` is a generator.** @param {Mixed} obj* @return {Boolean}* @api private*/function isGenerator(obj) {return 'function' == typeof obj.next && 'function' == typeof obj.throw;
}/*** Check if `obj` is a generator function.** @param {Mixed} obj* @return {Boolean}* @api private*/
function isGeneratorFunction(obj) {var constructor = obj.constructor;if (!constructor) return false;if ('GeneratorFunction' === constructor.name || 'GeneratorFunction' === constructor.displayName) return true;return isGenerator(constructor.prototype);
}/*** Check for plain object.** @param {Mixed} val* @return {Boolean}* @api private*/function isObject(val) {return Object == val.constructor;
}

这篇关于js的co.js源码解析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/853507

相关文章

用js控制视频播放进度基本示例代码

《用js控制视频播放进度基本示例代码》写前端的时候,很多的时候是需要支持要网页视频播放的功能,下面这篇文章主要给大家介绍了关于用js控制视频播放进度的相关资料,文中通过代码介绍的非常详细,需要的朋友可... 目录前言html部分:JavaScript部分:注意:总结前言在javascript中控制视频播放

SpringCloud动态配置注解@RefreshScope与@Component的深度解析

《SpringCloud动态配置注解@RefreshScope与@Component的深度解析》在现代微服务架构中,动态配置管理是一个关键需求,本文将为大家介绍SpringCloud中相关的注解@Re... 目录引言1. @RefreshScope 的作用与原理1.1 什么是 @RefreshScope1.

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

Python实现无痛修改第三方库源码的方法详解

《Python实现无痛修改第三方库源码的方法详解》很多时候,我们下载的第三方库是不会有需求不满足的情况,但也有极少的情况,第三方库没有兼顾到需求,本文将介绍几个修改源码的操作,大家可以根据需求进行选择... 目录需求不符合模拟示例 1. 修改源文件2. 继承修改3. 猴子补丁4. 追踪局部变量需求不符合很

Java的IO模型、Netty原理解析

《Java的IO模型、Netty原理解析》Java的I/O是以流的方式进行数据输入输出的,Java的类库涉及很多领域的IO内容:标准的输入输出,文件的操作、网络上的数据传输流、字符串流、对象流等,这篇... 目录1.什么是IO2.同步与异步、阻塞与非阻塞3.三种IO模型BIO(blocking I/O)NI

Python 中的异步与同步深度解析(实践记录)

《Python中的异步与同步深度解析(实践记录)》在Python编程世界里,异步和同步的概念是理解程序执行流程和性能优化的关键,这篇文章将带你深入了解它们的差异,以及阻塞和非阻塞的特性,同时通过实际... 目录python中的异步与同步:深度解析与实践异步与同步的定义异步同步阻塞与非阻塞的概念阻塞非阻塞同步

Redis中高并发读写性能的深度解析与优化

《Redis中高并发读写性能的深度解析与优化》Redis作为一款高性能的内存数据库,广泛应用于缓存、消息队列、实时统计等场景,本文将深入探讨Redis的读写并发能力,感兴趣的小伙伴可以了解下... 目录引言一、Redis 并发能力概述1.1 Redis 的读写性能1.2 影响 Redis 并发能力的因素二、

Spring MVC使用视图解析的问题解读

《SpringMVC使用视图解析的问题解读》:本文主要介绍SpringMVC使用视图解析的问题解读,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Spring MVC使用视图解析1. 会使用视图解析的情况2. 不会使用视图解析的情况总结Spring MVC使用视图

利用Python和C++解析gltf文件的示例详解

《利用Python和C++解析gltf文件的示例详解》gltf,全称是GLTransmissionFormat,是一种开放的3D文件格式,Python和C++是两个非常强大的工具,下面我们就来看看如何... 目录什么是gltf文件选择语言的原因安装必要的库解析gltf文件的步骤1. 读取gltf文件2. 提

Java中的runnable 和 callable 区别解析

《Java中的runnable和callable区别解析》Runnable接口用于定义不需要返回结果的任务,而Callable接口可以返回结果并抛出异常,通常与Future结合使用,Runnab... 目录1. Runnable接口1.1 Runnable的定义1.2 Runnable的特点1.3 使用Ru