函数式编程七: IO,task,Pointed,monad函子的学习

2023-10-20 14:20

本文主要是介绍函数式编程七: IO,task,Pointed,monad函子的学习,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

IO函子

  • IO函子中的_value是一个函数,这里把函数作为值来处理。
  • IO函子可以把不纯的动作存储到_ value中,延迟执行这个不纯的操作(惰性执行),包装当前的操作纯。
  • 把不纯的操作交给调用者来处理。
const fp = require("lodash/fp");
class IO {static of(x) {return new IO(function () {return x;});}constructor(fn) {this._value = fn;}map(fn) {//把当前的value和传入的fn组合成一个新的函数return new IO(fp.flowRight(fn, this._value));}
}

这个of方法接收的是一个数据,在of方法的里面再去返回一个io函子,调用io的构造函数传递一个函数,这个函数其实把传过来的值x包裹起来了,通过of可以看出,io函数最终还是想把这个值给返回,io函子的value保存的是一个函数,而这个函数返回的是一个值,把求值的过程做了延迟处理,想用这个值的时候再调 用io函子中的value这个函数。
io函子中的map方法,map方法还是接收一个fn函数,在map方法里通过调用io的构造函数来创建一个io的函子。

let r = IO.of(process).map((p) => p.execPath);
console.log(r);

在这里插入图片描述
结果返回的是一个io函子,io函子的value保存的是一个function,现在这个函数还没有被执行,可以直接执行r.value()。打印出当前执行node的路径。、
总结一下,io函子内部帮我们包装了一些函数,当我们在传递函数的时候有可能这个函数是一个不纯的函数,那我们不管这个函数是不是纯函数,io函子在执行的过程中,返回的结果始终是一个纯的操作。

Folktale异步执行

  • 异步任务的实现过于复杂,可以用folktale中的Task来演示。
  • folktale一个标准的函数式编程库
    • 和lodash,ramda不同的是,他没有提供很多功能函数。
    • 只提供了一些函数式处理的操作,例如:compose,curry等,一些函子Task\Either\MayBe等

先安装folktale这个库npm i folktale.

const { compose, curry } = require("folktale/core/lambda");
const { toUpper, first } = require("lodash/fp");
let f = compose(toUpper, first);
console.log(f(["one", "two"]));

在这里插入图片描述
Folktale这个库中的task函子来处理异步任务,用2.x版本的folktale来演示一个读取文件的例子。fs是读取文件

//Task处理异步任务
const fs = require("fs");
const { task } = require("folktale/concurrency/task");
function readFile(filename) {return task((resolver) => {fs.readFile(filename, "utf-8", (err, data) => {if (err) {resolver.reject(err);} else {resolver.resolve(data);}});});
}

调用一下上面的函数。

readFile("package-lock.json").run().listen({onRejected: (err) => {console.log(err);},onResolved: (value) => {console.log(value);},});

在这里插入图片描述
读取到了package-lock.json文件,如果想把lockfileVersion这个值解析出来,在onResolved我们拿到了这个value,如果直接在这里处理value的话会特别的麻烦,也不是函数式编程了,因为我们在readFile的时候,它返回的是一个task函子,而所有的函子都有一个map方法,所以在run之前可以调用一下这个函子的map方法,在这个方法里可以处理拿到的结果。
Package.json里其他就是一行一行的内容,可以先用换行对文本进行切割得到一个数组,然后再去寻找数组中带有lockfileVersion的这个数组。

const { split, find } = require("lodash/fp");readFile("package-lock.json").map(split("\n")).map(find((x) => x.includes("lockfileVersion"))).run().listen({onRejected: (err) => {console.log(err);},onResolved: (value) => {console.log(value);},});

在这里插入图片描述
Pointed函子,一点不陌生,因为我们一直在使用

  • Pointed函子是实现了 of静态方法的函子。
  • of方法是为了避免使用new来创建对象,更深层的含义是of方法用来把值放到了上下文 Context(把值放到容器中,使用map来处理值)。
class Container {static of(value) {return new Container(value);}// ......
}
Container.of(2).map((x) => x + 5);

接下去再学习最后一个函子,monad函子(单子),单细胞动物的意思
在使用IO函子的时候,如果之前写过如下代码

const fp = require("lodash/fp");
const fs = require("fs");
class IO {static of(value) {return new IO(function () {return value;});}constructor(fn) {this._value = fn;}map(fn) {return new IO(fp.flowRight(fn, this._value));}
}

我们先来看一个io函子的一个问题
在Linux5有一个cat命令,作用是读取文件的内容,并且把这个内容打印出来,写一个函数来模拟这个命令,先写一个读取文件的函数,再写一个打印的函数,组合成一个cat函数。

let readFile = function (filename) {return new IO(function () {return fs.readFileSync(filename, "utf-8");});
};
let print = function (x) {return new IO(function () {console.log(x);return x;});
};
let cat = fp.flowRight(print, readFile);
//IO(IO(x))
let r = cat("package-lock.json")._value()._value();
console.log(r);

最外面的IO是print返回的函子,最里面的io是readFile返回的函子。
在这里插入图片描述
这里面有一个问题,我们在嵌套函子的函数的时候非常的不方便,如果函子有嵌套的话,我们想要嵌套函子中的函数,需要._value()再.value(),虽然这样也可以去实现,但是这种api的风格看起来一般,可以改造一下。

  • Monad函子是可以变扁的PointedPointed函子,IO(IO(x)).
  • 一个函子如果具有join和 of两个方法并遵守一些定律就是一个 Monad.

把这个IO类改造成Monad函子,join()方法用来返回value结果,经常会把map和join联合起来使用。flatMap()的作用就是同时去调用map和join,上面的例子改造如下。

const fp = require("lodash/fp");
const fs = require("fs");
class IO {static of(value) {return new IO(function () {return value;});}constructor(fn) {this._value = fn;}map(fn) {return new IO(fp.flowRight(fn, this._value));}join() {return this._value();}flatMap(fn) {return this.map(fn).join();}
}let readFile = function (filename) {return new IO(function () {return fs.readFileSync(filename, "utf-8");});
};
let print = function (x) {return new IO(function () {console.log(x);return x;});
};
// let cat = fp.flowRight(print, readFile);
// //IO(IO(x))
// let r = cat("package-lock.json")._value()._value();
let r = readFile("package-lock.json").flatMap(print).join();
console.log(r);

再来复习一下monad函数,就是具有一个静态的io方法,并且具有一个join方法的函子,什么时候使用monad?当一个函数返回一个函子的时候,就可以使用monad来解决嵌套的问题,合并一个函数并且这个函数返回一个值,这时候可以调 用map方法,当我们想要合并一个函数,但是这个函数返回一个函子,这时可以用flatMap方法。

这篇关于函数式编程七: IO,task,Pointed,monad函子的学习的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

MySQL count()聚合函数详解

《MySQLcount()聚合函数详解》MySQL中的COUNT()函数,它是SQL中最常用的聚合函数之一,用于计算表中符合特定条件的行数,本文给大家介绍MySQLcount()聚合函数,感兴趣的朋... 目录核心功能语法形式重要特性与行为如何选择使用哪种形式?总结深入剖析一下 mysql 中的 COUNT

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁

MySQL 中 ROW_NUMBER() 函数最佳实践

《MySQL中ROW_NUMBER()函数最佳实践》MySQL中ROW_NUMBER()函数,作为窗口函数为每行分配唯一连续序号,区别于RANK()和DENSE_RANK(),特别适合分页、去重... 目录mysql 中 ROW_NUMBER() 函数详解一、基础语法二、核心特点三、典型应用场景1. 数据分

MySQL数据库的内嵌函数和联合查询实例代码

《MySQL数据库的内嵌函数和联合查询实例代码》联合查询是一种将多个查询结果组合在一起的方法,通常使用UNION、UNIONALL、INTERSECT和EXCEPT关键字,下面:本文主要介绍MyS... 目录一.数据库的内嵌函数1.1聚合函数COUNT([DISTINCT] expr)SUM([DISTIN

Python get()函数用法案例详解

《Pythonget()函数用法案例详解》在Python中,get()是字典(dict)类型的内置方法,用于安全地获取字典中指定键对应的值,它的核心作用是避免因访问不存在的键而引发KeyError错... 目录简介基本语法一、用法二、案例:安全访问未知键三、案例:配置参数默认值简介python是一种高级编

python 常见数学公式函数使用详解(最新推荐)

《python常见数学公式函数使用详解(最新推荐)》文章介绍了Python的数学计算工具,涵盖内置函数、math/cmath标准库及numpy/scipy/sympy第三方库,支持从基础算术到复杂数... 目录python 数学公式与函数大全1. 基本数学运算1.1 算术运算1.2 分数与小数2. 数学函数

Python中help()和dir()函数的使用

《Python中help()和dir()函数的使用》我们经常需要查看某个对象(如模块、类、函数等)的属性和方法,Python提供了两个内置函数help()和dir(),它们可以帮助我们快速了解代... 目录1. 引言2. help() 函数2.1 作用2.2 使用方法2.3 示例(1) 查看内置函数的帮助(

C++ 函数 strftime 和时间格式示例详解

《C++函数strftime和时间格式示例详解》strftime是C/C++标准库中用于格式化日期和时间的函数,定义在ctime头文件中,它将tm结构体中的时间信息转换为指定格式的字符串,是处理... 目录C++ 函数 strftipythonme 详解一、函数原型二、功能描述三、格式字符串说明四、返回值五

Go学习记录之runtime包深入解析

《Go学习记录之runtime包深入解析》Go语言runtime包管理运行时环境,涵盖goroutine调度、内存分配、垃圾回收、类型信息等核心功能,:本文主要介绍Go学习记录之runtime包的... 目录前言:一、runtime包内容学习1、作用:① Goroutine和并发控制:② 垃圾回收:③ 栈和

如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socket read timed out的问题

《如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socketreadtimedout的问题》:本文主要介绍解决Druid线程... 目录异常信息触发场景找到版本发布更新的说明从版本更新信息可以看到该默认逻辑已经去除总结异常信息触发场景复