当我调用 boost::asio::ip::tcp::resolver::async_resolve 时,我的处理程序收到一个 ip::tcp::resolver::iterator 迭代一个或多个 ip::tcp::resolver::entries。 他们的生命周期是多少,让他们活着的把柄是什么?
例如,如果我得到第一个 entry 并向它启动一个 tcp::async_connect,那么在 async_connect 处理程序中,可以我迭代到下一个 entry 并启动另一个 async_connect 到下一个条目(只要我将 iterator 传递给 async_connect 处理程序,当然)?
什么时候清理 resolver::iterator 和 resolver::entries?我是否需要做任何特别的事情,或者只是让它们超出范围并且不被任何回调闭包保留?
(我知道我可以在我的 async_resolve 处理程序中运行所有 resolver::entries 并将它们存储在智能指向结构或其他任何东西中,这样我控制它们的生命周期,但如果 asio::ip::tcp::resolver 已经在处理它,如果我让它完成它的工作,我的代码会更简单。)
最佳答案
迭代器具有值语义。因此它们的生命周期总是与周围对象的生命周期或它们的存储持续时间相关联(堆栈用于自动,堆用于动态,有时甚至是其他的,例如静态)。
我认为您想知道迭代器的有效性。
嗯,the documentation shows迭代器类别是 forward iterator .前向迭代器具有“多次通过保证”,允许重复取消对迭代器拷贝的引用,从而产生相同的结果¹。
所以,我们已经完成了一半:保留迭代器仍然可以。然而,当然,就像任何其他 [forward] 迭代器一样,我们必须考虑 iterator invalidation .
因此,真正的问题归结为:解析器迭代器何时失效。
resolve 函数实现的用例是连接。对于连接,第一个有效的端点就足够了,因此不需要它实际保留一个列表。
本着按需付费² 的 spirit ,解析器保持状态的时间超过所需时间是没有意义的。另一方面,如果不支持 Multipass,则将迭代器置于 ForwardIterator 类别中是没有意义的。
文档什么也没说。我们只有一种方法:深入研究代码
我们发现表面以下的一些步骤:asio/detail/resolver_service.hpp:73
// Asynchronously resolve a query to a list of entries.
template <typename Handler>
void async_resolve(implementation_type& impl,
const query_type& query, Handler& handler)
{
// Allocate and construct an operation to wrap the handler.
typedef resolve_op<Protocol, Handler> op;
typename op::ptr p = { boost::asio::detail::addressof(handler),
boost_asio_handler_alloc_helpers::allocate(
sizeof(op), handler), 0 };
resolve_op 显示迭代器是使用 basic_resolver_iterator.hpp::create 创建的
这让我们找到了答案:在 line 251 中
typedef std::vector<basic_resolver_entry<InternetProtocol> > values_type;
boost::asio::detail::shared_ptr<values_type> values_;
std::size_t index_;
因此,只要您保留有效迭代器(不是结束迭代器)的拷贝,您就可以继续取消引用它。它甚至会为每个解析器条目保留一份查询参数(host_name 和 service_name)。这看起来有点浪费,但我想在设计缓存方案时会派上用场。
翻译成“它们始终有效”(如果它们曾经有效的话)。
¹ 相对于例如输入迭代器
² 通常,C++ 实现遵循 零开销原则:不使用的东西,你不支付 [The Design and Evolution of C++, 1994]
关于c++ - async_resolve 的 boost::asio::ip::tcp::resolver::iterator 的生命周期是多少?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47048485/
我的瘦服务器配置了nginx,我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例,但找不到好的解决方案。有没有人能做到这一点? 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器,例如server{listen80;server
我有一个存储主机名的Ruby数组server_names。如果我打印出来,它看起来像这样:["hostname.abc.com","hostname2.abc.com","hostname3.abc.com"]相当标准。我想要做的是获取这些服务器的IP(可能将它们存储在另一个变量中)。看起来IPSocket类可以做到这一点,但我不确定如何使用IPSocket类遍历它。如果它只是尝试像这样打印出IP:server_names.eachdo|name|IPSocket::getaddress(name)pnameend它提示我没有提供服务器名称。这是语法问题还是我没有正确使用类?输出:ge
如何将send与+=一起使用?a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法,而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:
我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止,这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量,我
我有一个数组数组,想将元素附加到子数组。+=做我想做的,但我想了解为什么push不做。我期望的行为(并与+=一起工作):b=Array.new(3,[])b[0]+=["apple"]b[1]+=["orange"]b[2]+=["frog"]b=>[["苹果"],["橙子"],["Frog"]]通过推送,我将推送的元素附加到每个子数组(为什么?):a=Array.new(3,[])a[0].push("apple")a[1].push("orange")a[2].push("frog")a=>[[“苹果”、“橙子”、“Frog”]、[“苹果”、“橙子”、“Frog”]、[“苹果”、“
有没有办法让Ruby能够做这样的事情?classPlane@moved=0@x=0defx+=(v)#thisiserror@x+=v@moved+=1enddefto_s"moved#{@moved}times,currentxis#{@x}"endendplane=Plane.newplane.x+=5plane.x+=10putsplane.to_s#moved2times,currentxis15 最佳答案 您不能在Ruby中覆盖复合赋值运算符。任务在内部处理。您应该覆盖+,而不是+=。plane.a+=b与plane.a=
出于某种原因,heroku尝试要求dm-sqlite-adapter,即使它应该在这里使用Postgres。请注意,这发生在我打开任何URL时-而不是在gitpush本身期间。我构建了一个默认的Facebook应用程序。gem文件:source:gemcuttergem"foreman"gem"sinatra"gem"mogli"gem"json"gem"httparty"gem"thin"gem"data_mapper"gem"heroku"group:productiondogem"pg"gem"dm-postgres-adapter"endgroup:development,:t
我想在Ruby的TCPServer中获取客户端的IP地址。以及(如果可能的话)MAC地址。例如,Ruby中的时间服务器,请参阅评论。tcpserver=TCPServer.new("",80)iftcpserverputs"Listening"loopdosocket=tcpserver.acceptifsocketThread.newdoputs"Connectedfrom"+#HERE!HowcanigettheIPAddressfromtheclient?socket.write(Time.now.to_s)socket.closeendendendend非常感谢!
我是Ruby和这个网站的新手。下面两个函数是不同的,一个在函数外修改变量,一个不修改。defm1(x)x我想确保我理解正确-当调用m1时,对str的引用被复制并传递给将其视为x的函数。运算符当调用m2时,对str的引用被复制并传递给将其视为x的函数。运算符+创建一个新字符串,赋值x=x+"4"只是将x重定向到新字符串,而原始str变量保持不变。对吧?谢谢 最佳答案 String#+::str+other_str→new_strConcatenation—ReturnsanewStringcontainingother_strconc
我正在使用PostgreSQL9.1.3(x86_64-pc-linux-gnu上的PostgreSQL9.1.3,由gcc-4.6.real(Ubuntu/Linaro4.6.1-9ubuntu3)4.6.1,64位编译)和在ubuntu11.10上运行3.2.2或3.2.1。现在,我可以使用以下命令连接PostgreSQLsupostgres输入密码我可以看到postgres=#我将以下详细信息放在我的config/database.yml中并执行“railsdb”,它工作正常。开发:adapter:postgresqlencoding:utf8reconnect:falsedat