Question

My code:

while( Memo.qRcv.size() > 0) {
    MessageReceived msg=Memo.qRcv.poll();
    ...
}

Then I got

2014-03-01 11:09:36 DEBUG [Thread-16] (threadQueueSendtoUser.java:163) - Memo.qRcv = null, size = 41590
Was it helpful?

Solution

I found solution by using ConcurrentLinkedQueue http://www.javacodex.com/Concurrency/ConcurrentLinkedQueue-Example

Problem here is I used 2 thread to process a Queue, should not use normal queue. I will feedback if any problem

Thank you all

Licensed under: CC-BY-SA with attribution
Not affiliated with StackOverflow
scroll top