Go 实现Linq的探索-2-延迟计算

续上一篇的思路,解决延迟计算的问题。相关的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了

本文来自:开源中国博客

感谢作者:yuweikang

查看原文:Go 实现Linq的探索-2-延迟计算

• 编辑
• 预览