1

我被广泛ConcurrentLinkedQueue用于多任务队列，以前从未遇到过这个问题。场景如下：

  1. 用一些任务填满我的队列
  2. 运行多个线程（在这种特殊情况下为 2），这些线程将从队列中汇集任务
  3. 当队列不为空时，从队列中汇集并完成您的工作。

问题是，我的消费者正在汇集第一个元素 TWICE。为避免混淆，我已经检查了队列中的重复元素元素，但没有。到底是怎么回事？我不知道为什么，但同步queue.poll()并没有解决这个问题。如何解决这个问题？

我的队列轮询同步包装器（我以前不需要它，这仍然没有帮助） 编辑：正如我所指出的，它没有帮助，但我不得不尝试。提出正确的做法。

public class MultipleConsumerBlockingQueue<T> extends ConcurrentLinkedQueue<T> {
    private static final long serialVersionUID = 7994932568441881715L;
    private Logger log = LoggerFactory.getLogger(MultipleConsumerBlockingQueue.class);

    @Override
    public synchronized T poll() {
        T item = super.poll();
        return item;
    }

}

部分消费线程

        @Override
        public void run() {
            try {
                AdvancedSearchAgent agent = new AdvancedSearchAgent();
                while ((dp = queue.poll()) != null) {
                    log.info("**** for publication dates: {} - {}", sdf.format(dp.getFromDate()), sdf.format(dp.getToDate()));
                    agent.searchByPublicationDate(dp.getFromDate(), dp.getToDate());
                    log.info("Expected results count {} on {} pages", agent.getResultsCount(), agent.getPagesCount());
                    iterateOverResult(agent, handler);
                }
            } catch (Exception ex) {
                log.error("Unhanded error occured ****. Exiting method *****", ex);
            }

        }

生成的输出：

08:05:15.171 [main] INFO  ****  - Generated 10 date intervals for querying
08:05:15.174 [main] INFO  ****  - Created inner task 1
08:05:15.174 [main] INFO  ****  - Created inner task 2
Czas wykonania= 0 sekund  0 godzin 0 minut 0 sekund
08:05:15.178 [pool-2-thread-1] INFO  **** - **** for publication dates: 01-02-2013 - 03-03-2013
08:05:15.178 [pool-2-thread-2] INFO  **** - ****  for publication dates: 01-02-2013 - 03-03-2013

编辑：

这是队列中项目的转储。没有重复。

   1# -> Wt 2013-01-01 : Cz 2013-01-31
   2# -> Pt 2013-02-01 : N 2013-03-03
   3# -> Pn 2013-03-04 : Śr 2013-04-03
   4# -> Cz 2013-04-04 : So 2013-05-04
   5# -> N 2013-05-05 : Wt 2013-06-04
   6# -> Śr 2013-06-05 : Pt 2013-07-05
   7# -> So 2013-07-06 : Pn 2013-08-05
   8# -> Wt 2013-08-06 : Cz 2013-09-05
   9# -> Pt 2013-09-06 : N 2013-10-06
  10# -> Pn 2013-10-07 : Pt 2013-10-11
4

3 回答 3

2

ConcurrentLinkedQueue坏掉几乎是不可能的。多年来，它在数以百万计的文学应用程序中进行了测试，您可以保证不会两次轮询相同的元素。

我看不到你在哪里定义dp。如果这不是局部变量，我会感觉到一个潜在的候选者......尝试将它变成一个局部变量，看看它是否仍然出现。

此外，这听起来可能很愚蠢，但请确保您从一个相同ConcurrentLinkedQueue的对象进行轮询（通常像这样很愚蠢）。

于 2013-10-11T07:24:37.180 回答
2

我有一个常见的错误 - 它涉及 Dateformat 的 NonThreadSafety。从队列轮询很好，只生成了错误的日志。 sdf是工人共享的 SimpleDateFormat 对象（一开始它应该只是单线程，所以没人关心）。由于它不是线程安全的，因此格式化了错误的日期。太遗憾了，我之前没听懂。感谢所有的评论和指出。

于 2013-10-11T07:28:19.337 回答
0

你的synchronized方法永远不会像你期望的那样工作，因为ConcurrentLinkedQueue没有使用 Java Monitor Pattern for Thread Safety。它使用了一种不同的方法，如此处所述。

于 2013-10-11T06:44:40.643 回答