summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/util/WorkQueue.java
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main/java/com/orbekk/util/WorkQueue.java')
-rw-r--r--same/src/main/java/com/orbekk/util/WorkQueue.java14
1 files changed, 7 insertions, 7 deletions
diff --git a/same/src/main/java/com/orbekk/util/WorkQueue.java b/same/src/main/java/com/orbekk/util/WorkQueue.java
index 2fb2c88..397c4b8 100644
--- a/same/src/main/java/com/orbekk/util/WorkQueue.java
+++ b/same/src/main/java/com/orbekk/util/WorkQueue.java
@@ -16,21 +16,21 @@ abstract public class WorkQueue<E> extends Thread implements List<E> {
private Logger logger = LoggerFactory.getLogger(getClass());
private volatile List<E> list = null;
private volatile boolean done = false;
-
+
public WorkQueue() {
list = new ArrayList<E>();
}
-
+
public WorkQueue(Collection<? extends E> collection) {
list = new ArrayList<E>(collection);
}
-
+
public synchronized List<E> getAndClear() {
List<E> copy = new ArrayList<E>(list);
list.clear();
return copy;
}
-
+
/**
* OnChange event.
*
@@ -50,7 +50,7 @@ abstract public class WorkQueue<E> extends Thread implements List<E> {
onChange();
}
}
-
+
@Override
public void run() {
while (!done) {
@@ -71,8 +71,8 @@ abstract public class WorkQueue<E> extends Thread implements List<E> {
}
}
}
-
-
+
+
@Override
public synchronized boolean add(E e) {
notifyAll();