问题标签 [anyevent]

我怎样才能使计时器“可见”？这个例子返回（总是独立于睡眠时间）2（我期望类似于睡眠时间的东西）。

我正在开发一个使用AnyEvent. 在测试期间，我遇到了这样一种情况，即我的代码中的一个错误导致在我的测试完成后调用被阻塞的代码，因此测试看起来像是通过了，但后来被阻塞的调用最终污染了其他测试。

我想要发生的事情是在测试的拆解中，验证它AnyEvent没有等待任何其他被阻止的呼叫。这是否可以检查AnyEvent它是否有任何尚未执行的调用？

我们正在构建一个由模块组成的具有复杂逻辑的大型应用程序。我曾经用更简单的方法构建更大规模的方法，例如，

（这当然是简化的）。返回结果，抛出异常，每个人都很高兴。

现在，我们正在转向 AnyEvent。我的模块不是最上层，所以我不能只做

到目前为止，我见过的大多数 AE 模块都是这样工作的：

所以我已经重写了较低级别的方法并尝试继续使用 highlevel() 和......

不完全漂亮。我称之为“无限阶梯”。

现在我能想出的下一件事是一个临时状态机，其中 highlevel() 被分解为 _highlevel_stage1()、_highlevel_stage2() 等。但这也不能让我满意（它是不可维护的，并且认为很好名字而不是 stageXX 让我头疼）。

我们已经在研究一个成熟的状态机来驱动整个应用程序，但是必须为每个交互添加一个转换对我来说有点过于慷慨了。

所以问题是：编写实现业务逻辑（图 1）以在 AnyEvent 应用程序（图 3）中运行的模块的最佳实践是什么？

我使用带有 OAuth 身份验证的 cpan 库 AnyEvent::Twitter::Stream 做了一个推文爬虫，但我遇到了一些问题。有时，Twitter 会停止通过流 API 发送推文。然后，我让我的程序休眠一段时间，然后它应该返回以收集更多推文，但这并没有发生。该脚本只是继续尝试重新连接，但无法建立任何连接。会是什么呢？我的代码如下所示：

感谢大家，

蒂亚戈

有一种方法可以根据文档在聊天室中获取用户的昵称（roomName@domain.com/nick），但是如何获取用户的真实jid（name@domain.com/resource_name）？是否可以根据 XMPP 协议？

我对 perl 相对较新，甚至对 perl 中的线程也较新。我有一个 perl 脚本，它从 3 个不同的来源获取输入。（2 个 LDAP 查询和一个不总是存在的文件）因为某些部分可能比其他部分花费更长的时间，所以我决定使用线程和队列。在开发过程中，测试脚本的各个组件效果很好，但将它们放在一起后，性能似乎下降了。

基本结构是这 2 个线程：（读取文件或读取 AD 条目）-> Queue1 -> 2 个线程：（清理数据）-> Queue2 -> 3-4 个线程（与现有的本地 LDAP 条目比较）。几个线程将统计信息报告回主脚本，一旦所有线程完成，就会发送一封电子邮件，其中包含该运行的所有统计信息和状态。

我正在使用 dequeue_nb，我认为这会有所帮助，但没有运气。

性能冲击似乎在排队。在寻找提高性能的技巧时，我遇到了几篇文章，说 perl 线程不好，可以使用 coro、POE、Anyevent、IO:async 等。

这似乎不是一个“事件”问题，所以我认为 AnyEvent 或 POE 不会是我所看到的方式，coros 似乎一次只使用一个 CPU，所以我不确定这也行。我考虑过使用它们的组合，但后来我的头开始受伤。有没有人对如何修复/排除我的脚本或如何实现其他模块之一有任何建议？

我有以下子例程，并且有 appx 20 个线程使用不同的 URL 调用它（这个子程序属于一个包，每个线程调用该包的不同实例）：

($b,$e)变量仅用于测试。问题是，一段时间后，“开始”的数量似乎与“结束”的数量不匹配，因此它永远不会通过$cv->recv......我对 AnyEvent 和事件编程一般来说有点新，似乎解决我的问题。

谢谢，

我尝试使用 perl 模块 AnyEvent::HTTP 通过以下帖子发出异步 HTTP 请求：http: //www.windley.com/archives/2012/03/asynchronous_http_requests_in_perl_using_anyevent.shtml

但是，我无法让它通过代理工作......

我收到上述代码的以下错误（在用代理的身份验证详细信息替换后）

如果没有请求的代理参数，它就可以工作。从 CPAN 页面http://metacpan.org/pod/AnyEvent::HTTP，

595 - 连接建立、代理握手期间出错

请帮助我确定此代码的问题。谢谢！

我想对我正在跟踪的几千台机器（我自己的机器）做一些非阻塞SSH ，我有一个Dancer应用程序启动并运行，我愿意使用AnyEvent::timer来执行SSH异步命令（每台机器都有自己的轮询间隔，我不希望一台机器等待另一台机器完成其SSH工作）。

我想知道，在同步环境中异步操作的最佳方式是什么？

我写了一段代码：

工作一段时间后，物理存储已满。你能帮我用 AnyEvent 重写它吗？我试过了，但我的代码不起作用。我读到它会帮助我保护一些记忆。非常感谢任何帮助者。