课件及源代码地址

老师，有关于加厚模式的书推荐么？ 或者介绍各种架构模式的资料。

怎么让这个程序中的filter多线程执行

我使用go test -v，依旧显示./split_filter_test.go:9:8: undefined: NewSplitFilter，这是什么原因啊

老师，我想问一下split_filter.go 和 split_filter_test.go 再同一个package下，为什么split_filter_test.go无法引入NewSplitFilter啊？搞了好久没搞明白，代码无法运行。

func TestWrongInput(t *testing.T) { sf := NewSplitFilter(",") _, err := sf.Process(123) if err == nil { t.Fatal("An error is expected.") } } 是不是 if err != nil { t.Fatal("An error is expected.") }

这就是责任链+装饰器模式啊

例子代码写得真好，细节中看到很多差距，学习了

Filter 封装了数据处理功能，包括处理参数、填充、根据 Filter 内容召回广告或者排序 Filter 就是给它数据，然后等待数据处理的结果，只和数据格式或者数据类型耦合，只要传递给他的数据格式或者类型可以处理 在处理过程中可以加入新的 Filter 进行扩展 分布式系统中的 Pipe 可能需要一个网络连接或者在异步环境中的 buffer，在进程内部，就是方法调用 pipe-filter framework 类似于 Unix 或者 Linux 的管道指令 课程里面说可以形成组合模式，留言里面也有同学说类似于 责任链+装饰器模式

大佬好，不太理解 StraightPipeline 中的 `Filters *[]Filter` 为什么要声明成 切片指针类型呢

责任链模式。如果配合JAVA来对比说明可能效果会好一些。