java在有很多生产商的情况下如何改进Disruptor?
在我的程序中,它接收一个http请求,然后生成一个到RingBuffer
的事件。因为tomcat中有200个线程默认值,所以有200个生产者。每个线程一次生成一个事件,然后发布到RingBuffer
,在这种情况下,cpu使用率很高。如何解决这个问题?我在lmax disruptor is too slow in multi-producer mode compared to single-producer mode中找到了,但是queue merging thread
似乎对我不起作用,因为生产者线程是tomcat线程。这是我们可能的解决办法
使用multiRingBuffer
和Hash(thread)%RingBufferSize
决定发布事件的RingBuffer
有什么建议吗
共 (0) 个答案