1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.util.internal;
17
18 import java.io.Serializable;
19 import java.util.AbstractSet;
20 import java.util.Iterator;
21 import java.util.concurrent.ConcurrentHashMap;
22 import java.util.concurrent.ConcurrentMap;
23
24
25
26
27 @Deprecated
28 public final class ConcurrentSet<E> extends AbstractSet<E> implements Serializable {
29
30 private static final long serialVersionUID = -6761513279741915432L;
31
32 private final ConcurrentMap<E, Boolean> map;
33
34
35
36
37 public ConcurrentSet() {
38 map = new ConcurrentHashMap<>();
39 }
40
41 @Override
42 public int size() {
43 return map.size();
44 }
45
46 @Override
47 public boolean contains(Object o) {
48 return map.containsKey(o);
49 }
50
51 @Override
52 public boolean add(E o) {
53 return map.putIfAbsent(o, Boolean.TRUE) == null;
54 }
55
56 @Override
57 public boolean remove(Object o) {
58 return map.remove(o) != null;
59 }
60
61 @Override
62 public void clear() {
63 map.clear();
64 }
65
66 @Override
67 public Iterator<E> iterator() {
68 return map.keySet().iterator();
69 }
70 }