Ruby Fiber指南（一）基礎
??? Ruby Fiber指南（二）參數傳遞
??? Ruby Fiber指南（三）過濾器
???Ruby Fiber指南（四）迭代器
??? Ruby Actor指南（五）實現Actor

? ?? 在學習了Fiber的基礎知識之后，可以嘗試用Fiber去做一些比較有趣的事情。這一節將講述如何使用Fiber來實現類似unix系統中的管道功能。在unix系統中，可以通過管道將多個命令組合起來做一些強大的功能，最常用的例如查找所有的java進程：
ps?aux|grep?java 通過組合ps和grep命令來實現，ps的輸出作為grep的輸入，如果有更多的命令就形成了一條過濾鏈。過濾器本質上還是生產者和消費者模型，前一個過濾器產生結果，后一個過濾器消費這個結果并產生新的結果給下一個過濾器消費。因此我們就從最簡單的生產者消費者模型實現說起。
我們要展示的這個例子場景是這樣：生產者從標準輸入讀入用戶輸入并發送給消費者，消費者打印這個輸入，整個程序是由消費者驅動的，消費者喚醒生存者去讀用戶輸入，生產者讀到輸入后讓出執行權給消費者去打印，整個過程通過生產者和消費者的協作完成。
生產者發送是通過yield返回用戶輸入給消費者(還記的上一節嗎？）：

def?send(x)
??Fiber.yield(x)
end
而消費者的接收則是通過喚醒生產者去生產：
def?receive(prod)
??prod.resume
end
生產者是一個Fiber，它的任務就是等待用戶輸入并發送結果給消費者：
def?producer()
??Fiber.new?do
????while?true
??????x=readline.chomp
??????send(x)
????end
??end
end
消費者負責驅動生產者，并且在接收到結果的時候打印，消費者是root fiber:
def?consumer(producer)
??while?true
????x=receive(producer)
????break?if?x=='quit'
????puts?x
??end
end
??? 最終的調用如下：
consumer(producer()) ?? 完整的程序如下：

#生產者消費者
require?'fiber'

def?send(x)
??Fiber.yield(x)
end

def?receive(prod)
??prod.resume
end

def?producer()
??Fiber.new?do
????while?true
??????x=readline.chomp
??????send(x)
????end
??end
end


def?consumer(producer)
??while?true
????x=receive(producer)
????break?if?x=='quit'
????puts?x
??end
end
if?$0==__FILE__
??consumer(producer())
end

?? 讀者可以嘗試在ruby1.9下運行這個程序，每次程序都由消費者驅動生產者去等待用戶輸入，用戶輸入任何東西之后回車，生產者開始運行并將讀到的結果發送給消費者并讓出執行權（通過yield)，消費者在接收到yield返回的結果后打印這個結果，因此整個交互過程是一個echo的例子。

最終的調用consumer(producer())已經有過濾器的影子在了，如果我們希望在producer和consumer之間插入其他過程對用戶的輸入做處理，也就是安插過濾器，那么新的過濾器也將作為fiber存在，新的fiber消費producer的輸出，并輸出新的結果給消費者，例如我們希望將用戶的輸入結果加上行號再打印，那么就插入一個稱為filter的fiber:
def?filter(prod)
??return?Fiber.new?do
????line=1
????while?true
??????value=receive(prod)
??????value=sprintf("%5d?%s",line,value)
??????send(value)
??????line=line.succ
????end
??end
end
??? 最終組合的調用如下：
?consumer(filter(producer())) ?? 類似unix系統那樣，簡單的加入新的fiber組合起來就可以為打印結果添加行號。

類似consumer(filter(producer()))的調用方式盡管已經很直觀，但是我們還是希望能像unix系統那樣調用，也就是通過豎線作為管道操作符：
producer?|?filter?|?consumer 這樣的調用方式更將透明直觀，清楚地表明整個過濾器鏈的運行過程。幸運的是在Ruby中支持對|方法符的重載，因此要實現這樣的操作符并非難事,只要對Fiber做一層封裝即可，下面給出的代碼來自《Programming ruby》的作者Dave Thomas的blog：

class?PipelineElement
???attr_accessor?:source
???def?initialize
??????@fiber_delegate?=?Fiber.new?do
?????????process
??????end
???end

???def?|(other)
??????other.source?=?self
??????other
???end

???def?resume
??????@fiber_delegate.resume
???end

???def?process
??????while?value?=?input
?????????handle_value(value)
??????end
???end

???def?handle_value(value)
??????output(value)
???end

???def?input
??????@source.resume
???end

???def?output(value)
??????Fiber.yield(value)
???end
end

這段代碼非常巧妙，將Fiber和Ruby的功能展示的淋漓盡致。大致解說下，PipelineElement作為任何一個過濾器的父類，其中封裝了一個fiber，這個fiber默認執行process，在process方法中可以看到上面生產者和消費者例子的影子，input類似receive方法調用前置過濾器(source)，output則將本過濾器處理的結果作為參數傳遞給yield并讓出執行權，讓這個過濾器的調用者（也就是后續過濾器）得到結果并繼續處理。PipelineElement實現了“｜”方法，用于組合過濾器，將下一個過濾器的前置過濾器設置為本過濾器，并返回下一個過濾器。整個過濾鏈的驅動者是最后一個過濾器。

有了這個封裝，那么上面生產者消費者的例子可以改寫為：
class?Producer?<?PipelineElement
???def?process
?????while?true
???????value=readline.chomp
???????handle_value(value)
?????end
???end
end

class?Filter?<?PipelineElement
??def?initialize
????@line=1
????super()
??end
??def?handle_value(value)
????value=sprintf("%5d?%s",@line,value)
????output(value)
????@line=@line.succ
??end
end

class?Consumer?<?PipelineElement
??def?handle_value(value)
????puts?value
??end
end

?? 現在的調用方式可以跟unix的管道很像了：
producer=Producer.new
filter=Filter.new
consumer=Consumer.new

pipeline?=?producer?|?filter?|?consumer
pipeline.resume 如果你打印pipeline對象，你將看到一條清晰的過濾鏈,
#<Consumer:0x8f08bf4?@fiber_delegate=#<Fiber:0x8f08a88>,?@source=#<Filter:0x8f08db4?@line=1,?@fiber_delegate=#<Fiber:0x8f08d60>,?@source=#<Producer:0x8f09054?@fiber_delegate=#<Fiber:0x8f09038>>>> 文章轉自莊周夢蝶? ，原文發布時間2010-03-11
《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的Ruby Fiber指南（三）过滤器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。