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了

有疑问加站长微信联系（非本文作者）