[Bigdata-commit] SF.net SVN: bigdata:[3841] branches/QUADS_QUERY_BRANCH/bigdata/src/java/com /bigdata/bop/engine/RunningQuery.java

[<tho...@us...>]

Revision: 3841
          http://bigdata.svn.sourceforge.net/bigdata/?rev=3841&view=rev
Author:   thompsonbry
Date:     2010-10-22 20:08:48 +0000 (Fri, 22 Oct 2010)

Log Message:
-----------
Replaced use of LinkedHashMap with ConcurrentHashMap to avoid problems with concurrent modification arising from an iterator over a set whose contents are being changed from within a subroutine in the same thread (versus a second thread).

Modified Paths:
--------------
    branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/engine/RunningQuery.java

Modified: branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/engine/RunningQuery.java
===================================================================
--- branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/engine/RunningQuery.java	2010-10-22 19:58:41 UTC (rev 3840)
+++ branches/QUADS_QUERY_BRANCH/bigdata/src/java/com/bigdata/bop/engine/RunningQuery.java	2010-10-22 20:08:48 UTC (rev 3841)
@@ -452,7 +452,7 @@
 
         this.operatorFutures = new ConcurrentHashMap<BSBundle, ChunkFutureTask>();
         
-        this.operatorQueues = new LinkedHashMap<BSBundle, BlockingQueue<IChunkMessage<IBindingSet>>>();
+        this.operatorQueues = new ConcurrentHashMap<BSBundle, BlockingQueue<IChunkMessage<IBindingSet>>>();
         
         /*
          * Setup the BOpStats object for each pipeline operator in the query.


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.