diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-08 10:20:39 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-08 10:20:39 +0200 |
commit | 7bc7fe45b23f048a6bd609b7fbd01270b498a20b (patch) | |
tree | 69bb11e40dbc9c119f7461c430804d3ae9ef86af /same/src/main/java/com/orbekk/util/WorkQueue.java | |
parent | 561b6ab936f1b60d364e81b08322899a931ecc2e (diff) |
Get rid of queues in Master.
– Remove WorkQueue code.
– Remove delayed operations in master.
(Handled by RPC instead)
Diffstat (limited to 'same/src/main/java/com/orbekk/util/WorkQueue.java')
-rw-r--r-- | same/src/main/java/com/orbekk/util/WorkQueue.java | 229 |
1 files changed, 0 insertions, 229 deletions
diff --git a/same/src/main/java/com/orbekk/util/WorkQueue.java b/same/src/main/java/com/orbekk/util/WorkQueue.java deleted file mode 100644 index cfd5008..0000000 --- a/same/src/main/java/com/orbekk/util/WorkQueue.java +++ /dev/null @@ -1,229 +0,0 @@ -/** - * Copyright 2012 Kjetil Ørbekk <kjetil.orbekk@gmail.com> - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.orbekk.util; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.Iterator; -import java.util.List; -import java.util.ListIterator; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * A WorkList is a list for pending units of work. - */ -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. - * - * May be run even if the WorkQueue has not been changed. - * Called until the queue is empty. - */ - protected abstract void onChange(); - - /** - * Perform work until the queue is empty. - * - * Can be used for testing or for combining several WorkQueues in - * a single thread. - */ - public synchronized void performWork() { - while (!isEmpty()) { - onChange(); - } - } - - @Override - public void run() { - while (!done) { - if (!isEmpty()) { - onChange(); - } - synchronized (this) { - try { - if (isEmpty()) { - wait(); - } - } catch (InterruptedException e) { - done = true; - } - if (Thread.interrupted()) { - done = true; - } - } - } - } - - - @Override - public synchronized boolean add(E e) { - notifyAll(); - return list.add(e); - } - - @Override - public synchronized void add(int index, E element) { - notifyAll(); - list.add(index, element); - } - - @Override - public synchronized boolean addAll(Collection<? extends E> c) { - notifyAll(); - return list.addAll(c); - } - - @Override - public synchronized boolean addAll(int index, Collection<? extends E> c) { - notifyAll(); - return list.addAll(index, c); - } - - @Override - public synchronized void clear() { - notifyAll(); - list.clear(); - } - - @Override - public synchronized boolean contains(Object o) { - notifyAll(); - return list.contains(o); - } - - @Override - public synchronized boolean containsAll(Collection<?> c) { - notifyAll(); - return containsAll(c); - } - - @Override - public synchronized E get(int index) { - notifyAll(); - return list.get(index); - } - - @Override - public synchronized int indexOf(Object o) { - notifyAll(); - return list.indexOf(o); - } - - @Override - public synchronized boolean isEmpty() { - notifyAll(); - return list.isEmpty(); - } - - @Override - public synchronized Iterator<E> iterator() { - notifyAll(); - return list.iterator(); - } - - @Override - public synchronized int lastIndexOf(Object o) { - notifyAll(); - return list.lastIndexOf(o); - } - - @Override - public synchronized ListIterator<E> listIterator() { - notifyAll(); - return list.listIterator(); - } - - @Override - public synchronized ListIterator<E> listIterator(int index) { - notifyAll(); - return list.listIterator(index); - } - - @Override - public synchronized boolean remove(Object o) { - notifyAll(); - return list.remove(o); - } - - @Override - public synchronized E remove(int index) { - notifyAll(); - return list.remove(index); - } - - @Override - public synchronized boolean removeAll(Collection<?> c) { - notifyAll(); - return list.removeAll(c); - } - - @Override - public synchronized boolean retainAll(Collection<?> c) { - notifyAll(); - return list.retainAll(c); - } - - @Override - public synchronized E set(int index, E element) { - notifyAll(); - return list.set(index, element); - } - - @Override - public synchronized int size() { - notifyAll(); - return list.size(); - } - - @Override - public synchronized List<E> subList(int fromIndex, int toIndex) { - notifyAll(); - return list.subList(fromIndex, toIndex); - } - - @Override - public synchronized Object[] toArray() { - notifyAll(); - return list.toArray(); - } - - @Override - public synchronized <T> T[] toArray(T[] a) { - notifyAll(); - return list.toArray(a); - } - -} |