[Gzz-commits] storm/org/nongnu/storm/impl AsyncSetCollector.java

[Benja Fallenstein]

CVSROOT:        /cvsroot/storm
Module name:    storm
Changes by:     Benja Fallenstein <address@hidden>      03/05/02 09:28:39

Modified files:
        org/nongnu/storm/impl: AsyncSetCollector.java 

Log message:
        simple fix

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/org/nongnu/storm/impl/AsyncSetCollector.java.diff?tr1=1.8&tr2=1.9&r1=text&r2=text

Patches:
Index: storm/org/nongnu/storm/impl/AsyncSetCollector.java
diff -u storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.8 
storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.9
--- storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.8      Fri Apr 25 
08:27:55 2003
+++ storm/org/nongnu/storm/impl/AsyncSetCollector.java  Fri May  2 09:28:38 2003
@@ -141,8 +141,10 @@
        }
        addCollectionListener(new CollectionListener() {
                public boolean item(Object item) {
-                   queue.add(item);
-                   queue.notifyAll();
+                   synchronized(queue) {
+                       queue.add(item);
+                       queue.notifyAll();
+                   }
                    return true;
                }
                public void finish(boolean timeout) {