Ruby中实现stream
2023-03-14 10:21:35 时间
流是通过延时求值实现的,Ruby中实现stream也是可以做到,可惜就是没有尾递归优化。按照sicp,首要的是两个函数:delay和force:
最后,看下例子:
def mem_proc(exp)
alread_run=false
result=false
lambda{
if !alread_run
result=exp.call
alread_run=true
result
else
result
end
}
end
def force(delayed_object)
delayed_object.call
end
def delay(exp)
mem_proc(lambda{exp})
end
delay函数返回延时对象,就是对于未来某个时间求值表达式的承诺;force函数以延时对象为参数,进行相应的求值工作,这里的mem_proc用于记忆已经求值过的表达式。定义stream的constructor和selector函数:alread_run=false
result=false
lambda{
if !alread_run
result=exp.call
alread_run=true
result
else
result
end
}
end
def force(delayed_object)
delayed_object.call
end
def delay(exp)
mem_proc(lambda{exp})
end
def cons_stream(a,b)
return a,delay(b)
end
def stream_car(s)
s[0]
end
def stream_cdr(s)
force(s[1])
end
def stream_null?(s)
s.nil? or s==[]
end
用Ruby中的数组充当“粘合剂”,stream_car直接返回第一个元素,而stream_cdr需要用force求值表达式,履行承诺。另外,将空数组[]作为the-empty-stream。再定义几个高阶函数,map和foreach,其他如filter与此类似:return a,delay(b)
end
def stream_car(s)
s[0]
end
def stream_cdr(s)
force(s[1])
end
def stream_null?(s)
s.nil? or s==[]
end
def stream_enumerate_interval(low,high)
if low>high
return []
else
cons_stream(low,stream_enumerate_interval(low.succ,high))
end
end
def stream_ref(s,n)
if n==0
stream_car(s)
else
stream_ref(stream_cdr(s),(n-1))
end
end
def stream_map(proc,s)
if stream_null?(s)
[]
else
cons_stream(proc.call(stream_car(s)),stream_map(proc,(stream_cdr(s))))
end
end
def stream_for_each(proc,s)
if stream_null?(s)
:done
else
proc.call(stream_car(s))
stream_for_each(proc,stream_cdr(s))
end
end
def display_stream(s)
stream_for_each(lambda{|item| puts item},s)
end
def stream_filter(pred,s)
if stream_null?(s)
[]
elsif pred.call(stream_car(s))
cons_stream(stream_car(s),stream_filter(pred,stream_cdr(s)))
else
stream_filter(pred,stream_cdr(s))
end
end
if low>high
return []
else
cons_stream(low,stream_enumerate_interval(low.succ,high))
end
end
def stream_ref(s,n)
if n==0
stream_car(s)
else
stream_ref(stream_cdr(s),(n-1))
end
end
def stream_map(proc,s)
if stream_null?(s)
[]
else
cons_stream(proc.call(stream_car(s)),stream_map(proc,(stream_cdr(s))))
end
end
def stream_for_each(proc,s)
if stream_null?(s)
:done
else
proc.call(stream_car(s))
stream_for_each(proc,stream_cdr(s))
end
end
def display_stream(s)
stream_for_each(lambda{|item| puts item},s)
end
def stream_filter(pred,s)
if stream_null?(s)
[]
elsif pred.call(stream_car(s))
cons_stream(stream_car(s),stream_filter(pred,stream_cdr(s)))
else
stream_filter(pred,stream_cdr(s))
end
end
最后,看下例子:
puts "s:"
s=stream_enumerate_interval(1,5)
display_stream(s)
puts "odd_s:"
odd_s=stream_filter(lambda{|x| x%2==1},s)
display_stream(odd_s)
puts "ss:"
ss=stream_map(lambda{|x|x*x},s)
display_stream(ss)
s=stream_enumerate_interval(1,5)
display_stream(s)
puts "odd_s:"
odd_s=stream_filter(lambda{|x| x%2==1},s)
display_stream(odd_s)
puts "ss:"
ss=stream_map(lambda{|x|x*x},s)
display_stream(ss)
文章转自庄周梦蝶 ,原文发布时间2008-05-08
相关文章
- 我居然在Github上找到了一个完整的停车系统
- Python pyspider的安装与开发
- 用Metrics Server对Kubernetes集群实现全面资源监控
- SpringBoot定时任务及Cron表达式详解
- 你不知道的 VSCode 代码高亮原理
- PHP如何实现依赖注入
- 面试侃集合 | SynchronousQueue非公平模式篇
- 用鸿蒙开发板制作一个空压机储气罐自动排水装置
- 我被编程语言PUA了:用互联网黑话写代码,每天都在“赋能”变量
- 关于PHP协程与阻塞的思考
- 一篇学会资源库Repository的性能优化
- 如何使用开源MOSH获得持久性的SSH连接?
- PHP基础|如何解决中文乱码问题?
- 适用所有程序员的3种提高编程技能的方法
- Python Decorator基础
- 一日一技:等待多个线程同时结束的两种方法
- 嵌入式开发输出调试和日志信息的几种方法
- 机器学习算法实践:朴素贝叶斯 (Naive Bayes)
- 消息队列解耦是骗小孩儿的
- 前端浏览器缓存知识梳理