Scalaz(33)- Free :算式-Monadic Programming

在任何模式的编程过程中都无法避免副作用的产生。我们可以用F[A]这种类型模拟FP的运算指令:A是可能产生副作用的运算,F[_]是个代数数据类型ADT(Algebraic Data Type),可以实现函数组合(functional composition),我们可以不用理会A,先用F[_]来组合形成描述功能的抽象程序AST(Abstract Syntax Tree),对A的运算可以分开另一个过程去实现,而且可以有多种的运算实现方式,这样就达到了算式AST(Monadic Programming)、算法(Interpretation)的所谓关注分离(separation of concern)目的。在前面的讨论中我们介绍过:我们可以把任何F[A]升格成Monad,而Monad具备最完善的函数组合性能,特别是它支持for-comprehension这种表达方式。我们可以在for-comprehension框架里进行我们熟悉的行令编程(imperative programming),可以使程序意思表达更加显而易见。

下面我们来做一个简单的示范:模拟一个互动智力算数测试(math quiz):在系统提示下,用户输入第一个数字、再输入第二个数字、再输入操作符号、系统输出算数操作结果。我们可以设计ADT如下:

1 sealed trait Quiz[+Next]
2 case class Question[Next](que: String, n: String => Next) extends Quiz[Next]
3 case class Answer[Next](ans: String, n: Next) extends Quiz[Next]

Quiz类型可能属于Question或Answer。Question需要读取一个String类型输入,由于实际需要的可能是一个Int或者是Char,在获取输入后还要进行下一步类型转换(map),所以还必须把一个转换函数String=>Next存放入Question结构。Answer则不需要任何输入,所以我们会把()作为Next的值存入Answer结构。

我们可以map over Next类型获取Quiz的Functor实例:

1   implicit object QFunctor extends Functor[Quiz] {
2     def map[A,B](qa: Quiz[A])(f: A => B): Quiz[B] =
3       qa match {
4          case q: Question[A] => Question(q.que, q.n andThen f)
5          case Answer(a,n) => Answer(a,f(n))
6       }
7   }

从case q: Question[A]可以看出来:map over Next实际上是连续运算(andThen)。

我们再来几个操作帮助方法:

 1 //操作帮助方法helper methods
 2   def askNumber(q: String) = Question(q, (inputString => inputString.toInt))  //_.toInt
 3   def askOperator(q: String) = Question(q, (inputString => inputString.head.toUpper.toChar))
 4   def answer(fnum: Int, snum: Int, opr: Char) = {
 5     def result =
 6       opr match {
 7         case 'A' => fnum + snum
 8         case 'M' => fnum * snum
 9         case 'D' => fnum / snum
10         case 'S' => fnum - snum
11       }
12     Answer("my answer is: " + result.toString,())
13   }

我们现在可以这样编写AST了: 

1 import Quiz._
2 val prg = for {
3  fn <- askNumber("The first number is:")
4  sn <- askNumber("The second number is:")
5  op <- askOperator("The operation is:")
6  _ <- answer(fn,sn,op)
7 } yield()                                         //> prg  : scalaz.Free[Exercises.interact.Quiz,Unit] = Gosub()

但是,askNumber,askOperator及answer这几个操作函数都返回了Quiz类型,而Quiz类型不是Monad,不支持for-comprehension。我们可以用个隐式转换把所有Quiz[A]升格成Free[Quiz,A]:

1   implicit def quizToFree[A](qz: Quiz[A]): Free[Quiz,A] = Free.liftF(qz)

这个示范完整的源代码如下:

 1 sealed trait Quiz[+Next]
 2 object Quiz {
 3 //问题que:String, 等待String 然后转成数字或操作符号
 4   case class Question[Next](que: String, n: String => Next) extends Quiz[Next]
 5   case class Answer[Next](ans: String, n: Next) extends Quiz[Next]
 6   implicit object QFunctor extends Functor[Quiz] {
 7     def map[A,B](qa: Quiz[A])(f: A => B): Quiz[B] =
 8       qa match {
 9          case q: Question[A] => Question(q.que, q.n andThen f)
10          case Answer(a,n) => Answer(a,f(n))
11       }
12   }
13 //操作帮助方法helper methods
14   def askNumber(q: String) = Question(q, (inputString => inputString.toInt))  //_.toInt
15   def askOperator(q: String) = Question(q, (inputString => inputString.head.toUpper.toChar)) //_.head.toUpper.toChar
16   def answer(fnum: Int, snum: Int, opr: Char) = {
17     def result =
18       opr match {
19         case 'A' => fnum + snum
20         case 'M' => fnum * snum
21         case 'D' => fnum / snum
22         case 'S' => fnum - snum
23       }
24     Answer("my answer is: " + result.toString,())
25   }
26   implicit def quizToFree[A](qz: Quiz[A]): Free[Quiz,A] = Free.liftF(qz)
27 }
28 import Quiz._
29 val prg = for {
30  fn <- askNumber("The first number is:")
31  sn <- askNumber("The second number is:")
32  op <- askOperator("The operation is:")
33  _ <- answer(fn,sn,op)
34 } yield()                                         //> prg  : scalaz.Free[Exercises.interact.Quiz,Unit] = Gosub()

再看看下面的例子。试着猜测程序的作用:

 1 sealed trait Calc[+A]
 2 object Calc {
 3   case class Push(value: Int) extends Calc[Unit]
 4   case class Add() extends Calc[Unit]
 5   case class Mul() extends Calc[Unit]
 6   case class Div() extends Calc[Unit]
 7   case class Sub() extends Calc[Unit]
 8   implicit def calcToFree[A](ca: Calc[A]) = Free.liftFC(ca)
 9 }
10 import Calc._
11 val ast = for {
12   _ <- Push(23)
13   _ <- Push(3)
14   _ <- Add()
15   _ <- Push(5)
16   _ <- Mul()
17 } yield ()                                        //> ast  : scalaz.Free[[x]scalaz.Coyoneda[Exercises.interact.Calc,x],Unit] = Gosub()

从上面的AST表达方式可以估计到这是一个对Int进行加减乘除的计算器,应该是先通过push把操作对象存入一个Stack。然后对Stack内部的数字进行计算操作。具体是如何实现的,在这个阶段无需知道,这应该是Interpreter的工作。这个例子不就真正体现了算式算法的关注分离了的精髓嘛。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java帮帮-微信公众号-技术文章全总结

Java多线程详解2

Java多线程详解 Java线程:线程的同步与锁 一、同步问题提出 线程的同步是为了防止多个线程访问一个数据对象时,对数据造成的破坏。 例如:两个线程Threa...

3297
来自专栏青枫的专栏

JDK5中Lock锁的使用

(1)JDK5中Lock锁的使用   虽然我们可以理解同步代码块和同步方法的锁对象问题,但是我们并没有直接看到在哪里加上了锁,在哪里释放了锁,为了更清晰的...

281
来自专栏python百例

108-多线程的效率

python的多线程有一个GIL(全局解释器锁),使得多个线程,某一时刻只有一个线程发送给CPU处理。所以多线程不适用计算密集型应用,更适合IO密集型应用。 ...

734
来自专栏好好学java的技术栈

java基础提升篇:深入浅出Java多线程

982
来自专栏java达人

百万级数据查询优化(数据库)

1.对查询进行优化,应尽量避免全表扫描,首先应考虑在 where 及 order by 涉及的列上建立索引。 2.应尽量避免在 where 子句中对字段进行 n...

1979
来自专栏Kevin-ZhangCG

[ Java面试题 ]多线程篇

2457
来自专栏Java成长之路

深入理解多线程

多线程是java中比较重要的一部分内容,使用多线程有许多的优点: - 提高应用程序的响应。对图形化界面更有意义,可增强用户体验。 - 程序需要实现一些需...

863
来自专栏精讲JAVA

百万数据查询优化技巧三十则

对查询进行优化,应尽量避免全表扫描,首先应考虑在 where 及 order by 涉及的列上建立索引。 应尽量避免在 where 子句中对字段进行 null ...

1809
来自专栏开发与安全

linux网络编程之posix 线程(四):posix 条件变量与互斥锁 示例生产者--消费者问题

一、posix 条件变量 一种线程间同步的情形:线程A需要等某个条件成立才能继续往下执行,现在这个条件不成立,线程A就阻塞等待,而线程B在执行过程中使这个条件成...

1870
来自专栏JMCui

多线程编程学习三(线程间通信).

一、概要 线程是操作系统中独立的个体,但这些个体如果不经过特殊的处理就不能成为一个整体,线程间的通信就是成为整体的必用方案之一。可以说,使线程进行通信后,系统...

2604

扫码关注云+社区