3

我正在对 Disruptor Queues 的内部 C 实现进行性能测试,我很想对非线程事件流处理的其他类似方法进行基准测试。谷歌上的内容很少,因此非常感谢任何指针或建议。

4

3 回答 3

2

具有 C++ 源的队列目录可能可以移植到 C):

http://www.1024cores.net/home/lock-free-algorithms/queues/queue-catalog

已经将其中一个移植到 Scala 并获得比标准 java.util.concurrent.ConcurrentLinkedQueue 更好的延迟和吞吐量:

https://github.com/plokhotnyuk/actors/blob/c92576e3b200180ee1c8ea521fb668c538f125ab/src/main/scala/com/github/plokhotnyuk/actors/MPSCQueue.scala

于 2012-07-12T13:06:36.713 回答
2

这里有一个 C 实现:

https://github.com/colding/disruptorC

请注意 README 中关于性能的说明。

于 2012-07-23T12:29:41.313 回答
0

我会检查 ØMQ 并通过 PUSH/PULL sockets使用他们的线程间通信传输zmq_inproc。通信是单向的,但却是最快的选择。

于 2013-02-12T17:17:24.567 回答