BT

如何利用碎片时间提升技术认知与能力? 点击获取答案

Facebook为C++11带来了健壮且强大的Folly Futures库

| 作者 Sergio De Simone 关注 14 他的粉丝 ,译者 金灵杰 关注 5 他的粉丝 发布于 2015年7月31日. 估计阅读时间: 5 分钟 | 如何结合区块链技术,帮助企业降本增效?让我们深度了解几个成功的案例。

Future是一种用于同步并发操作的构件,它能够被视为对异步操作结果的只读代理对象,这个对象的初始值是未知的。如果Future的客户端试图在操作完成前读取它的值,

可能会被阻塞。Future通常和一个Promise关联,Promise提供对Future的值进行写访问。

异步操作能够立即返回只读的Future,而不阻塞,示例代码片段如下:

#include <folly/futures/Future.h>
using folly::Future;
Future<Output> asyncOperation(Input);
Future<Output> f = asyncOperation(input);

这里的asyncOperation是一个异步调用的包装。Future的客户端能够通过isReady()方法检查其关联的Promise是否已经完成,并通过value()方法获取其结果。

Future由它关联的Promise创建,当异步操作完成时,可以通过setValue()或者setWith()方法设置它的结果:

using folly::Promise;
Future<double> getEnergy(int year) {
  auto promise = make_shared<Promise<double>>();
  std::thread([=]{
    promise->setWith(std::bind(getEnergySync, year));
  }).detach();
  return promise->getFuture();
}

Folly Futures库真正强大之处在于其Future::then方法,该方法能够方便地进行链式回调,避免进入回调地狱(callback hell)。回调链可以这样来表示:

Future<OutputA> futureA(Output);
Future<OutputB> futureB(OutputA);
Future<OutputC> futureC(OutputB);
OutputD d(OutputC) {
  if (somethingExceptional) throw anException;
  return OutputD();
}
Future<double> fut =
  fooFuture(input)
  .then(futureA)
  .then(futureB)
  .then(futureC)
  .then(d)
  .then([](OutputD outputD) { // 同样支持lambda表达式
    return outputD * M_PI;
  });

Folly Futures库提供的另一个强大的构建块是集合方法,它允许将Future集合视为一个Future,这个Future在集合中的全部Future完成时完成。

和集合方法类似,Folly Futures库还提供了方法:

  • collectAny:当集合中的任何一个Future完成时即完成。
  • collectN:等待N个Future完成后完成。
  • map:参数为Future集合和一个函数,针对集合参数中的每个Future,调用函数参数的then()方法。返回值是一个新的Future数组。
  • reduce:参数为Future集合和带有两个参数的函数(reduce的值和reduce序列中的下一个值),针对集合参数中的每个Future,依次调用函数参数。

最后,Folly Futures还支持通过执行上下文来控制回调的执行。例如,你能够给then方法传入一个执行器对象,指定此次回调应该通过这个执行器来执行:

struct Executor {
  using Func = std::function<void()>;
  virtual void add(Func) = 0;
};
a(input).then(executor, b);

更多信息可以参见Folly Future的文档

查看英文原文:Facebook Folly Brings Robust, Powerful Futures to C++11


感谢丁晓昀对本文的审校。

给InfoQ中文站投稿或者参与内容翻译工作,请邮件至editors@cn.infoq.com。也欢迎大家通过新浪微博(@InfoQ@丁晓昀),微信(微信号:InfoQChina)关注我们,并与我们的编辑和其他读者朋友交流(欢迎加入InfoQ读者交流群InfoQ好读者)。

 

评价本文

专业度
风格

您好,朋友!

您需要 注册一个InfoQ账号 或者 才能进行评论。在您完成注册后还需要进行一些设置。

获得来自InfoQ的更多体验。

告诉我们您的想法

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我
社区评论

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

讨论

登陆InfoQ,与你最关心的话题互动。


找回密码....

Follow

关注你最喜爱的话题和作者

快速浏览网站内你所感兴趣话题的精选内容。

Like

内容自由定制

选择想要阅读的主题和喜爱的作者定制自己的新闻源。

Notifications

获取更新

设置通知机制以获取内容更新对您而言是否重要

BT