Libraryless. Click here for Pure Java version (132L/1K).
persistable static class SynchronizedCollection<E> implements Collection<E>, Serializable { @java.io.Serial private static final long serialVersionUID = 3053995032091335093L; @SuppressWarnings("serial") // Conditionally serializable /*final*/ Collection<E> c; // Backing Collection @SuppressWarnings("serial") // Conditionally serializable /*final*/ Object mutex; // Object on which to synchronize SynchronizedCollection(Collection<E> c) { this.c = Objects.requireNonNull(c); mutex = this; } SynchronizedCollection(Collection<E> c, Object mutex) { this.c = Objects.requireNonNull(c); this.mutex = Objects.requireNonNull(mutex); } public int size() { synchronized (mutex) {return c.size();} } public boolean isEmpty() { synchronized (mutex) {return c.isEmpty();} } public boolean contains(Object o) { synchronized (mutex) {return c.contains(o);} } public Object[] toArray() { synchronized (mutex) {return c.toArray();} } public <T> T[] toArray(T[] a) { synchronized (mutex) {return c.toArray(a);} } public <T> T[] toArray(java.util.function.IntFunction<T[]> f) { synchronized (mutex) {return c.toArray(f);} } public Iterator<E> iterator() { return c.iterator(); // Must be manually synched by user! } public boolean add(E e) { synchronized (mutex) {return c.add(e);} } public boolean remove(Object o) { synchronized (mutex) {return c.remove(o);} } public boolean containsAll(Collection<?> coll) { synchronized (mutex) {return c.containsAll(coll);} } public boolean addAll(Collection<? extends E> coll) { synchronized (mutex) {return c.addAll(coll);} } public boolean removeAll(Collection<?> coll) { synchronized (mutex) {return c.removeAll(coll);} } public boolean retainAll(Collection<?> coll) { synchronized (mutex) {return c.retainAll(coll);} } public void clear() { synchronized (mutex) {c.clear();} } public String toString() { synchronized (mutex) {return c.toString();} } // Override default methods in Collection @Override public void forEach(java.util.function.Consumer<? super E> consumer) { synchronized (mutex) {c.forEach(consumer);} } @Override public boolean removeIf(java.util.function.Predicate<? super E> filter) { synchronized (mutex) {return c.removeIf(filter);} } @Override public Spliterator<E> spliterator() { return c.spliterator(); // Must be manually synched by user! } @Override public java.util.stream.Stream<E> stream() { return c.stream(); // Must be manually synched by user! } @Override public java.util.stream.Stream<E> parallelStream() { return c.parallelStream(); // Must be manually synched by user! } @java.io.Serial private void writeObject(ObjectOutputStream s) throws IOException { synchronized (mutex) {s.defaultWriteObject();} } }
download show line numbers debug dex old transpilations
Travelled to 17 computer(s): aoiabmzegqzx, bhatertpkbcr, cbybwowwnfue, cfunsshuasjs, gwrvuhgaqvyk, imzmzdywqqli, ishqpsrjomds, jtubtzbbkimh, lpdgvwnxivlt, mqqgnosmbjvj, onxytkatvevr, ppjhyzlbdabe, pyentgdyhuwx, pzhvpgtvlbxg, tslmcundralx, tvejysmllsmz, vouqrxazstgt
No comments. add comment
Snippet ID: | #1009403 |
Snippet name: | SynchronizedCollection [not copied from JDK] |
Eternal ID of this version: | #1009403/16 |
Text MD5: | 2e31ce5697888aa59138283d59221c79 |
Transpilation MD5: | 277872da4ed21243acc3230188d504e4 |
Author: | stefan |
Category: | javax |
Type: | JavaX fragment (include) |
Public (visible to everyone): | Yes |
Archived (hidden from active list): | No |
Created/modified: | 2021-05-16 17:46:22 |
Source code size: | 3212 bytes / 93 lines |
Pitched / IR pitched: | No / No |
Views / Downloads: | 623 / 2679 |
Version history: | 15 change(s) |
Referenced in: | #1009405 - CollectionInConcept #1031169 - SynchronizedCollection [not copied from JDK] #1034167 - Standard Classes + Interfaces (LIVE, continuation of #1003674) |