1 files changed, 122 insertions, 0 deletions
diff --git a/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/iterators/SynchronizedListIterator.java b/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/iterators/SynchronizedListIterator.java
new file mode 100644
index 0000000000..87e6384bf5
--- /dev/null
+++ b/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/iterators/SynchronizedListIterator.java
@@ -0,0 +1,122 @@
+/*******************************************************************************
+ * Copyright (c) 2009, 2010 Oracle. All rights reserved.
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0, which accompanies this distribution
+ * and is available at http://www.eclipse.org/legal/epl-v10.html.
+ * 
+ * Contributors:
+ *     Oracle - initial API and implementation
+ ******************************************************************************/
+package org.eclipse.jpt.common.utility.internal.iterators;
+
+import java.util.List;
+import java.util.ListIterator;
+
+import org.eclipse.jpt.common.utility.internal.StringTools;
+import org.eclipse.jpt.common.utility.internal.iterables.ListIterable;
+
+/**
+ * Wrap a list iterator and synchronize all its methods so it can be safely shared
+ * among multiple threads.
+ * 
+ * @param <E> the type of elements returned by the iterator
+ */
+public class SynchronizedListIterator<E>
+	implements ListIterator<E>
+{
+	private final ListIterator<E> listIterator;
+
+	/** Object to synchronize on. */
+	private final Object mutex;
+
+
+	public SynchronizedListIterator(List<E> list) {
+		this(list.listIterator());
+	}
+
+	public SynchronizedListIterator(List<E> list, Object mutex) {
+		this(list.listIterator(), mutex);
+	}
+
+	public SynchronizedListIterator(ListIterable<E> listIterable) {
+		this(listIterable.iterator());
+	}
+
+	public SynchronizedListIterator(ListIterable<E> listIterable, Object mutex) {
+		this(listIterable.iterator(), mutex);
+	}
+
+	public SynchronizedListIterator(ListIterator<E> listIterator) {
+		super();
+		this.listIterator = listIterator;
+		this.mutex = this;
+	}
+
+	public SynchronizedListIterator(ListIterator<E> listIterator, Object mutex) {
+		super();
+		this.listIterator = listIterator;
+		this.mutex = mutex;
+	}
+
+	public synchronized boolean hasNext() {
+		synchronized (this.mutex) {
+			return this.listIterator.hasNext();
+		}
+	}
+
+	public synchronized E next() {
+		synchronized (this.mutex) {
+			return this.listIterator.next();
+		}
+	}
+
+	public synchronized int nextIndex() {
+		synchronized (this.mutex) {
+			return this.listIterator.nextIndex();
+		}
+	}
+
+	public synchronized boolean hasPrevious() {
+		synchronized (this.mutex) {
+			return this.listIterator.hasPrevious();
+		}
+	}
+
+	public synchronized E previous() {
+		synchronized (this.mutex) {
+			return this.listIterator.previous();
+		}
+	}
+
+	public synchronized int previousIndex() {
+		synchronized (this.mutex) {
+			return this.listIterator.previousIndex();
+		}
+	}
+
+	public synchronized void remove() {
+		synchronized (this.mutex) {
+			this.listIterator.remove();
+		}
+	}
+
+	public synchronized void add(E e) {
+		synchronized (this.mutex) {
+			this.listIterator.add(e);
+		}
+	}
+
+	public synchronized void set(E e) {
+		synchronized (this.mutex) {
+			this.listIterator.set(e);
+		}
+	}
+
+	@Override
+	public String toString() {
+		synchronized (this.mutex) {
+			return StringTools.buildToStringFor(this, this.listIterator);
+		}
+	}
+
+}