[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Gzz-commits] storm/org/nongnu/storm/impl AsyncSetCollector.java
From: |
Benja Fallenstein |
Subject: |
[Gzz-commits] storm/org/nongnu/storm/impl AsyncSetCollector.java |
Date: |
Fri, 02 May 2003 09:28:39 -0400 |
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) {
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Gzz-commits] storm/org/nongnu/storm/impl AsyncSetCollector.java,
Benja Fallenstein <=