My code:
while( Memo.qRcv.size() > 0) {
MessageReceived msg=Memo.qRcv.poll();
...
}
然后我得到了
2014-03-01 11:09:36 DEBUG [Thread-16] (threadQueueSendtoUser.java:163) - Memo.qRcv = null, size = 41590
我通过使用 ConcurrentLinkedQueue 找到了解决方案http://www.javacodex.com/Concurrency/ConcurrentLinkedQueue-示例 http://www.javacodex.com/Concurrency/ConcurrentLinkedQueue-Example
这里的问题是我使用了 2 个线程来处理一个队列，不应该使用普通队列。如果有任何问题我会反馈
谢谢你们
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
