[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, 25 Apr 2003 06:53:56 -0400 |
CVSROOT: /cvsroot/storm
Module name: storm
Changes by: Benja Fallenstein <address@hidden> 03/04/25 06:53:56
Modified files:
org/nongnu/storm/impl: AsyncSetCollector.java
Log message:
try fix
CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/org/nongnu/storm/impl/AsyncSetCollector.java.diff?tr1=1.6&tr2=1.7&r1=text&r2=text
Patches:
Index: storm/org/nongnu/storm/impl/AsyncSetCollector.java
diff -u storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.6
storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.7
--- storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.6 Tue Apr 22
09:01:21 2003
+++ storm/org/nongnu/storm/impl/AsyncSetCollector.java Fri Apr 25 06:53:56 2003
@@ -152,6 +152,9 @@
public boolean hasNext() {
if(!queue.isEmpty())
return true;
+ else if(isFinished())
+ return false;
+
synchronized(queue) {
try {
queue.wait();
@@ -160,9 +163,11 @@
return !queue.isEmpty();
}
public Object next() {
- if(!queue.isEmpty()) {
+ if(!queue.isEmpty())
return queue.remove(0);
- }
+ else if(isFinished())
+ throw NoSuchElementException();
+
synchronized(queue) {
try {
queue.wait();
- [Gzz-commits] storm/org/nongnu/storm/impl AsyncSetCollector.java,
Benja Fallenstein <=