当有许多生产商时,如何改进disruptor?

k2fxgqgv  于 2021-06-29  发布在  Java
关注(0)|答案(0)|浏览(170)

在我的程序中,它接收一个http请求,然后生成一个 RingBuffer . 因为tomcat中有200个线程默认值,所以有200个生产者。每个线程一次生成一个事件,然后发布到 RingBuffer ,在这种情况下cpu使用率很高。如何解决这个问题?我发现在lmaxdisruptor是太慢,在多生产者模式相比,单生产者模式,但 queue merging thread 似乎不适合我,因为生产者线程是tomcat线程。这是我们可能的解决办法
使用多 RingBuffer 以及 Hash(thread)%RingBufferSize 决定发布事件的ringbuffer
有什么建议吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题