Fantastic. Future 也许就像它的名字一样,真是Future。 非常感谢能继续介绍这些新兴的模块。对我这种懒人来说，真的是帮助非常大。 本来卡住的思想，又能继续前进。差点就要自己写一个类似的东西了，发现有人已经做了，真是一种幸福的感觉。殊途同归啊！
Perl的未来也许不是perl6，而是perl5的不断翻新。 在 2014年12月8日 下午10:29，chenlin rao <[email protected]>写道： > # Future > > 这个名字一听起来还以为是要说 Perl 的发展方向之类的吧。其实我这里要介绍的是一个 CPAN 模块，或者说，一种异步编程模式在 Perl 里的运用。 > > Future 模式的定义之类的，大家可以看 Java 或者 C++ 的资料，都会有提。这里直接进入 Perl 相关的部分。[Future 模块]( > https://metacpan.org/pod/Future)的作者是著名的 Paul Evans，[IO::Async 模块]( > https://metacpan.org/pod/IO::Async)的作者。事实上 IO::Async 模块现在已经完全依赖于 Future > 模块了。 > > 考虑大家其实用 AnyEvent 周边模块比较多，这里展示如何在 AnyEvent 环境里，使用 Future。示例脚本及解释如下： > > ## 首先加载程序要用的模块及导出函数 > > use 5.20.0; > use experimental 'signatures'; > use AnyEvent; > use AnyEvent::HTTP; > use AnyEvent::Future qw/as_future/; > use Future::Utils qw/fmap/; > > ## 为 AnyEvent 的异步函数封装成 Future 对象 > > `as_future` 接收一个匿名函数，内部封装异步操作，这里就是最常见的 `http_get`，匿名函数会传递进去一个 Future > 对象。而在异步操作的回调中，我们可以调用该 Future 对象的 **implementation methods**(These methods > would primarily be used by implementations of asynchronous interfaces)。 > > 最常见的就是 `->done(@results)` 和 `->fail($exception, @details)` > 两个方法，分别传递成功和失败的消息。 > > 这里示例中就是判断只有响应码在 2XX 的时候，成功返回网页；否则失败报错。 > > sub future_get($url) { > return as_future { > my $f = shift; > http_get $url, sub($body, $hdr) { > if ( $hdr->{Status} =~ /^2/ ) { > $f->done($body); > } > else { > $f->fail( $url . " got " . $hdr->{Reason} ); > } > }; > } > > `as_future` 的返回值，也就是这个 Future 对象。所以，我们可以继续在这个对象上调用 Future 的 **sequencing > methods**(These methods all return a new future to represent the > combination of its invocant followed by another action given by a code > reference)。 > > 最常见的，是 `->then( \&code(@result) )` `->else( \&code($exception) > )`。注意为了让链式调用可以继续下去，这里的匿名函数一定也要返回一个新的 Future 对象。 > > 这里示例，就只判断一下失败的报错信息，如果是 404 Not Found，可以认为服务器本身没问题，依然返回一个成功的 > Future。事实上这里完全可以再使用其他的异步操作。 > > ->else( > sub($exception) { > if ( $exception =~ /Not Found/ ) { > Future->done("OK, now."); > } > else { > Future->fail($exception); > } > } > ); > }; > > 好了，函数定义完成。你就可以直接使用了。 > > ## 多个 Future 对象的协同工作 > > 单个 url 下载当然没什么意思，我们这里需要一些复杂逻辑来协同工作。下面这段的效果是：并发 5 个请求请求 URL 列表，但是超过 5 > 秒没完成就直接停止。 > > my @urls = qw( http://www.baidu.com http://www.baidu http://www ); > my $future = Future->wait_any( > AnyEvent::Future->new_timeout( after => 5 ), > fmap { future_get(shift) } foreach => \@urls, concurrent => 5 > ); > > 这其中用的是 Future 的 convergent futures(These constructors all take a list of > component futures, and return a new future whose readiness somehow depends > on the readiness of those components)，也就是传入由多个 Future 对象构成的数组，返回一个新的 Future > 对象。 > > 常见的有 > `->wait_any(@futures)`、`->wait_all(@futures)`、`->needs_all(@futures)`、`->needs_any(@futures)` > 四种。wait 表示有返回即可，needs 则要求返回的为成功才行。 > > `fmap` 则是 [Future::Utils](https://metacpan.org/pod/Future::Utils) > 模块额外提供的函数，用来方便的控制循环操作和并发等。模块里还提供了 `repeat`、`try_repeat`、`fmap_concat` > 等其他函数和 `while`、`otherwise` 等其他循环控制。 > > 如果这里不用控制，直接简单一点，可以写成一行： > > my $future = Future->needs_all( map { future_get($_) } @urls ); > > ## 正式运行 > > 前面这么多，都还是在定义阶段。现在可以准备运行了。跟运行相关的，叫做 user methods(These methods would > primarily be used by users of asynchronous interfaces, on objects returned > by such an interface)。 > > 最常用的，有`->get`、`->on_done`、`->on_fail`、`->on_ready`、`->failure` 等。 > > 这里的逻辑是：Future 运行完成的状态，叫 **ready**。ready 且 done 的状态，返回的数据通过 **get** > 获取；ready 但是 fail 的状态，返回的数据通过 **failure** 获取。 > > $future->on_done( sub { say "everything is ok" } ); > $future->on_fail( sub { say "something wrong!" } ); > $future->get; > > ## 运行结果 > > 把上面几段代码连起来保存成文件并运行，可以看到如下结果： > > > something wrong! > > http://www.baidu got Device not configured at future.pl line 43. > > 试试自己修改一下 urls 数组的内容，看看结果如何吧？ > > ## 参考 > > Future 的详细用法示例，大家可以上 pevans 个人博客上看他去年的 [future advent]( > http://leonerds-code.blogspot.jp/2013/12/futures-advent-day-1.html) > 系列。顺带一说，今年他个人博客是又在写响应式编程模式的文章，说不准之后又会推出相应模块吧… > > > > http://advent.perl-china.com/calendar/2014/08/ > > -- > 您收到此邮件是因为您订阅了Google网上论坛上的“PerlChina Mongers 讨论组”群组。 > 要退订此群组并停止接收此群组的电子邮件，请发送电子邮件到[email protected]。 > 要发帖到此群组，请发送电子邮件至[email protected]。 > 访问此群组：http://groups.google.com/group/perlchina。 > 要查看更多选项，请访问https://groups.google.com/d/optout。 > -- 您收到此邮件是因为您订阅了 Google 网上论坛的“PerlChina Mongers 讨论组”论坛。 要退订此论坛并停止接收此论坛的电子邮件，请发送电子邮件到[email protected]。 要向此网上论坛发帖，请发送电子邮件至 [email protected]。 通过以下网址访问此论坛：http://groups.google.com/group/perlchina。 要查看更多选项，请访问 https://groups.google.com/d/optout。
