续上一篇的思路,解决延迟计算的问题。相关的keyword很容易想到yield。
在C#中的延迟计算介绍可以参考一些文章,例如 “不能不说的C#特性-迭代器(下) yield以及流的延迟计算”
http://www.cnblogs.com/yuyijq/archive/2008/07/19/1246609.html
文章中提到
一、每次只返回一个元素的方法(阅读者请跳到下文的第二部分)
从一个比较形式化的角度想,需要一个函数,每次调用去除列表最前面的元素,如果列表为空,返回false。
type iterator func()(bool,interface{})
然后在使用的时候,for循环每次都会判断获取的bool返回值为true的话,输出结果。
for ok, next := iter(); ok; ok, next = iter() {
fmt.Println(next)
}
定义一个包含上面提到的方法和列表的数据结构
type Query struct{
list []interface{}
}
iter是iterator类型的,它的责任是每次只去除列表的头一个元素,并对空列表的情况做判断。
func (q *Query)GetIterator() iterator{
i:=0
return func() (bool,interface{}){
if i < len(q.list) {
ret := q.list[i]
i++
return true,ret
}
return false,nil
}
}
下面的方法用于添加数据
func (q *Query)generator(data interface{}){
q.list = append(q.list,data)
}
第一次在Go上使用单例模式:once.Do
var m *Query
var once sync.Once
func GeneratorInstance() *Query{
once.Do(func() {
m = &Query {}
})
return m
}
下面开始检查这种方法
func quips(name string) iterator{
GeneratorInstance().generator("Hi " + name + "!")
GeneratorInstance().generator("Hi" +
" good day , R u ok?")
GeneratorInstance().generator("en.. ok,good day")
return GeneratorInstance().GetIterator()
}
func main() {
iter := quips("Yk kang")
for ok, next := iter(); ok; ok, next = iter() {
fmt.Println(next)
}
}
执行后会输出:
Hi Yk kang2!
Hi good day , R u ok?
en.. ok,good day
二、与切片结合,让笔记“探索一”里面From().Select()支持延迟计算
其实质就是把From改造成像上文GetIterator的样子;而Query不保存list,list由From输入,Query声明了返回item的方法
type Iterator func()(item interface{},ok bool)
type Query struct{
Iterate func() Iterator
}
func From(in interface{}) Query{
src := reflect.ValueOf(in)
len := src.Len()
return Query{
Iterate:func() Iterator{
i:=0
return func() (item interface{},ok bool){
ok = i < len
if ok{
item = src.Index(i).Interface()
i++
}
return
}
},
}
}
next := From(userArr).Iterate()
for item,ok := next(); ok; item,ok = next() {
fmt.Println(item)
}
这样便会正常输出
{1 A 12}
{2 B 7}
{3 C 15}
而Select方法传入的参数是selector func (interface{}) interface{},在方法体里面从From返回的Query的Iterate方法得到item,ok,传进selector里面,因此Select方法是Query的
func (q Query) Select(selector func(interface{}) interface{}) Query {
return Query{
Iterate: func() Iterator {
next := q.Iterate()
return func() (item interface{}, ok bool) {
var it interface{}
it, ok = next()
if ok {
item = selector(it)
}
return
}
},
}
}
//使用
t := From(userArr).Select(func(c interface{}) interface{}{
return c.(User).Name
})
next := t.Iterate()
for item,ok := next(); ok; item,ok = next() {
fmt.Println(item)
}
按照这个函数链的逻辑,where方法也可以照搬Select了