前几天项目总是报错,找了下原因。
ConcurrentLinkedQueue 本身是一个基于链接节点的无界线程安全队列,你自己调用就不用考虑线程安全了吗?
结论是:原子性操作当然是线程安全的,非原子性那就不安全了
原子性操作:
queue.add(obj);
or
queue.poll();
非原子性操作(这里涉及到两个操作,在大并发的时候,在两个方法之间,在中间这个时刻,即当调用完了queue.isEmpty()的时候,可能有人操作了queue.poll(),在当你调用queue.poll()的时候,队列已经为空了,所以就出现异常了)
if(!queue.isEmpty()) { queue.poll(); }
应该为下面:
synchronized(queue) { if(!queue.isEmpty()) { queue.poll(); } }
参考:http://stackoverflow.com/questions/435069/java-util-concurrentlinkedqueue/435941