# Origin: http://gist.github.com/4631<\/span>\n# Poor Man's Fiber (API compatible Thread based Fiber implementation for Ruby 1.8)<\/span>\n# (c) 2008 Aman Gupta (tmm1)<\/span>\n\nunless<\/span> defined?<\/span> Fiber<\/span>\n require<\/span> 'thread'<\/span>\n\n class<\/span> FiberError<\/span> <<\/span> StandardError<\/span>;<\/span> end<\/span>\n\n class<\/span> Fiber<\/span>\n def<\/span> initialize<\/span>\n raise<\/span> ArgumentError<\/span>,<\/span> 'new Fiber requires a block'<\/span> unless<\/span> block_given?<\/span>\n\n @yield<\/span> =<\/span> Queue<\/span>.<\/span>new<\/span>\n @resume<\/span> =<\/span> Queue<\/span>.<\/span>new<\/span>\n\n @thread<\/span> =<\/span> Thread<\/span>.<\/span>new<\/span>{<\/span> @yield<\/span>.<\/span>push<\/span> [<\/span> *<\/span>yield<\/span>(<\/span>*<\/span>@resume<\/span>.<\/span>pop<\/span>)<\/span> ]<\/span> }<\/span>\n @thread<\/span>.<\/span>abort_on_exception<\/span> =<\/span> true<\/span>\n @thread<\/span>[<\/span>:fiber<\/span>]<\/span> =<\/span> self<\/span>\n end<\/span>\n attr_reader<\/span> :thread<\/span>\n\n def<\/span> resume<\/span> *<\/span>args<\/span>\n raise<\/span> FiberError<\/span>,<\/span> 'dead fiber called'<\/span> unless<\/span> @thread<\/span>.<\/span>alive?<\/span>\n @resume<\/span>.<\/span>push<\/span>(<\/span>args<\/span>)<\/span>\n result<\/span> =<\/span> @yield<\/span>.<\/span>pop<\/span>\n result<\/span>.<\/span>size<\/span> ><\/span> 1<\/span> ?<\/span> result<\/span> :<\/span> result<\/span>.<\/span>first<\/span>\n end<\/span>\n\n def<\/span> yield<\/span> *<\/span>args<\/span>\n @yield<\/span>.<\/span>push<\/span>(<\/span>args<\/span>)<\/span>\n result<\/span> =<\/span> @resume<\/span>.<\/span>pop<\/span>\n result<\/span>.<\/span>size<\/span> ><\/span> 1<\/span> ?<\/span> result<\/span> :<\/span> result<\/span>.<\/span>first<\/span>\n end<\/span>\n\n def<\/span> self<\/span>.<\/span>yield<\/span> *<\/span>args<\/span>\n raise<\/span> FiberError<\/span>,<\/span> "can't yield from root fiber"<\/span> unless<\/span> fiber<\/span> =<\/span> Thread<\/span>.<\/span>current<\/span>[<\/span>:fiber<\/span>]<\/span>\n fiber<\/span>.<\/span>yield<\/span>(<\/span>*<\/span>args<\/span>)<\/span>\n end<\/span>\n\n def<\/span> self<\/span>.<\/span>current<\/span>\n Thread<\/span>.<\/span>current<\/span>[<\/span>:fiber<\/span>]<\/span> or<\/span> raise<\/span> FiberError<\/span>,<\/span> 'not inside a fiber'<\/span>\n end<\/span>\n\n def<\/span> inspect<\/span>\n "#<<\/span>#{<\/span>self<\/span>.<\/span>class<\/span>}<\/span>:0x<\/span>#{<\/span>self<\/span>.<\/span>object_id<\/span>.<\/span>to_s<\/span>(<\/span>16<\/span>)<\/span>}<\/span>>"<\/span>\n end<\/span>\n end<\/span>\nend<\/span>\n\nif<\/span> __FILE__<\/span> ==<\/span> $0<\/span>\n f<\/span> =<\/span> Fiber<\/span>.<\/span>new<\/span>{<\/span> puts<\/span> 'hi'<\/span>;<\/span> p<\/span> Fiber<\/span>.<\/span>yield<\/span>(<\/span>1<\/span>);<\/span> puts<\/span> 'bye'<\/span>;<\/span> :done<\/span> }<\/span>\n p<\/span> f<\/span>.<\/span>resume<\/span>\n p<\/span> f<\/span>.<\/span>resume<\/span>(<\/span>2<\/span>)<\/span>\nend<\/span>\n\n__END__<\/span>\n\n$ ruby fbr.rb <\/span>\nhi<\/span>\n1<\/span>\n2<\/span>\nbye<\/span>\n:done<\/span>\n\n$ ruby1.9 fbr.rb <\/span>\nhi<\/span>\n1<\/span>\n2<\/span>\nbye<\/span>\n:done<\/span>\n<\/pre><\/div>\n');
document.write('
');
document.write('
');
document.write('
');
document.write('