Python中的LMAX中断器
是否已经有了Python3的实现（或至少绑定到Python3）？
我可以看到Github上有一个原始的Java实现，但我没有看到Python3的任何内容。
共有1个答案
数据管道提供了简单的基于cython的实现：
- https://pypi.org/project/data-pipe/
- https://github.com/random-python/data_pipe
-
我有一个环形缓冲区和一个事件处理程序。这用作消息传递服务器的入站缓冲区。 在偶处理程序中，它执行一些AMQP服务调用，有时由于调用没有超时而等待（下划线协议库中调用AMQP服务的错误）。对于2000tps，这使我的4096大小的环形缓冲区在一瞬间就满了。因为由于上述事实，onEvent调用线程似乎没有从该方法返回，并且在onEvent（）内无限等待。 目前，不可能为该调用创建超时。 问题是： 当d
-
我是LMAX Disruptor的新手，我正在探索将其用于需要处理巨大流量的多层异步项目。 请求被传递到平台以发送SMS，请求被清理/检查简单错误并被记录。 获取并分析与发送SMS的客户端相关的各种其他信息，并将其他参数添加到SMS信息中。 分析并选择正确的路由。然后从SMS信息中设置特定于平台的协议参数并提交给路由器。 像这样，将有接收和处理短信传递到日志、账单、重试和许多其他的流程。在每个阶段
-
我想使用Lmax Disruptor进行性能测试： 配置DURUPTOR 以某种方式“暂停”处理 向RingBuffer添加多条消息 “取消暂停”处理 这样，我可以清楚地测量缓冲区清空的速度。如果我“混合”添加了许多消息（这会带来一些延迟）并进行处理，那么在处理速度方面可能会有不太确定的结果。 然而，我似乎没有在LMAX Disruptor（https://lmax-exchange.github
-
我们有一个使用Disruptor框架的系统，它有五个注册阶段来实现EvenetHandler。 阶段按顺序工作，因此请求只能在第一阶段完成时移动到第二阶段，该移动由Disruptor内部维护。 我们对第三阶段有问题，这是瓶颈，需要大量时间，因为它进行不同的HTTP调用并将响应存储在请求对象中。 因此，我们希望在第三阶段花了一段时间之后，将请求（无论有什么响应）提前到第四和第五阶段。 如何超时任何特
-
在使用disruptor时，可能会有一个（多个）消费者落后，并且由于这个缓慢的消费者，整个应用程序都会受到影响。 请记住，每个生产者（发布者）和消费者（EventProcessor）都在一个线程上运行，如何解决消费者速度慢的问题？ 我们可以在单个消费者上使用多个线程吗？如果没有，有什么更好的选择？
-
问题内容： 我需要使用ctrl c从time.sleep（）中断。 在上面的代码中，当控件进入time.sleep函数时，整整60秒钟需要经过python处理CTRL C 有什么优雅的方法可以做到这一点。这样我就可以在控件处于及时状态时中断我的睡眠功能 编辑 我在一个旧的实现中对其进行了测试，该实现在Windows 2000上使用python 2.2，这引起了所有麻烦。如果我使用了更高版本的pyt