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
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
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With