I had written a program to test the performance of bigqueue, the program have 1 producer thread and 1 consumer thread. I'm adding messages in 1 thread and reading messages in another thread simultaneously. I have got following result :
Producer thread written 9 million messages with speed of around 125 MB/S.
Consumer thread managed to read just over 2 a million record in same time with speed of around 35 MB/S.
Now when I read separately the reading speed is around 95 MB/S.
The significant difference between the reading speed when I read sequentially and when I read randomly due is due to synchronization or this is abnormal and I'm doing it in wrong way.
I had written a program to test the performance of bigqueue, the program have 1 producer thread and 1 consumer thread. I'm adding messages in 1 thread and reading messages in another thread simultaneously. I have got following result : Producer thread written 9 million messages with speed of around 125 MB/S. Consumer thread managed to read just over 2 a million record in same time with speed of around 35 MB/S.
Now when I read separately the reading speed is around 95 MB/S.
The significant difference between the reading speed when I read sequentially and when I read randomly due is due to synchronization or this is abnormal and I'm doing it in wrong way.
Kindly let me know