/*
 * Copyright (c) 2021 Goldman Sachs and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * and Eclipse Distribution License v. 1.0 which accompany this distribution.
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at
 * http://www.eclipse.org/org/documents/edl-v10.php.
 */

package org.eclipse.collections.impl;

import java.io.Externalizable;
import java.io.IOException;
import java.io.ObjectInput;
import java.io.ObjectOutput;
import java.io.Serializable;

import org.eclipse.collections.api.RichIterable;
import org.eclipse.collections.impl.collection.AbstractSynchronizedRichIterable;

A synchronized view of a RichIterable.
Since:5.0
/** * A synchronized view of a RichIterable. * * @since 5.0 */
public class SynchronizedRichIterable<T> extends AbstractSynchronizedRichIterable<T> implements Serializable { private static final long serialVersionUID = 2L; protected SynchronizedRichIterable(RichIterable<T> iterable) { this(iterable, null); } protected SynchronizedRichIterable(RichIterable<T> iterable, Object newLock) { super(iterable, newLock); }
This method will take a RichIterable and wrap it directly in a SynchronizedRichIterable.
/** * This method will take a RichIterable and wrap it directly in a SynchronizedRichIterable. */
public static <E> SynchronizedRichIterable<E> of(RichIterable<E> iterable) { return new SynchronizedRichIterable<>(iterable); } protected Object writeReplace() { return new SynchronizedRichIterableSerializationProxy<>(this.getDelegate()); }
This method will take a RichIterable and wrap it directly in a SynchronizedRichIterable. Additionally, a developer specifies which lock to use with the collection.
/** * This method will take a RichIterable and wrap it directly in a SynchronizedRichIterable. Additionally, * a developer specifies which lock to use with the collection. */
public static <E> SynchronizedRichIterable<E> of(RichIterable<E> iterable, Object lock) { return new SynchronizedRichIterable<>(iterable, lock); } public static class SynchronizedRichIterableSerializationProxy<T> implements Externalizable { private static final long serialVersionUID = 1L; private RichIterable<T> richIterable; @SuppressWarnings("UnusedDeclaration") public SynchronizedRichIterableSerializationProxy() { // Empty constructor for Externalizable class } public SynchronizedRichIterableSerializationProxy(RichIterable<T> iterable) { this.richIterable = iterable; } @Override public void writeExternal(ObjectOutput out) throws IOException { out.writeObject(this.richIterable); } @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { this.richIterable = (RichIterable<T>) in.readObject(); } protected Object readResolve() { return new SynchronizedRichIterable<>(this.richIterable); } } }