我的代码:
while( Memo.qRcv.size() > 0) {
MessageReceived msg=Memo.qRcv.poll();
...
}
Run Code Online (Sandbox Code Playgroud)
然后我得到了
2014-03-01 11:09:36 DEBUG [Thread-16] (threadQueueSendtoUser.java:163) - Memo.qRcv = null, size = 41590
Run Code Online (Sandbox Code Playgroud)
我通过使用 ConcurrentLinkedQueue http://www.javacodex.com/Concurrency/ConcurrentLinkedQueue-Example找到了解决方案
这里的问题是我使用了 2 个线程来处理一个队列,不应该使用普通队列。如果有任何问题我会反馈
谢谢你们
| 归档时间: |
|
| 查看次数: |
1599 次 |
| 最近记录: |