1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.mina.util;
21
22 import java.io.Serializable;
23 import java.util.Collection;
24 import java.util.Iterator;
25 import java.util.Queue;
26
27
28
29
30
31
32
33
34
35 public class SynchronizedQueue<E> implements Queue<E>, Serializable {
36
37 private static final long serialVersionUID = -1439242290701194806L;
38
39 private final Queue<E> queue;
40
41
42
43
44
45
46 public SynchronizedQueue(Queue<E> queue) {
47 this.queue = queue;
48 }
49
50
51
52
53 @Override
54 public synchronized boolean add(E e) {
55 return queue.add(e);
56 }
57
58
59
60
61 @Override
62 public synchronized E element() {
63 return queue.element();
64 }
65
66
67
68
69 @Override
70 public synchronized boolean offer(E e) {
71 return queue.offer(e);
72 }
73
74
75
76
77 @Override
78 public synchronized E peek() {
79 return queue.peek();
80 }
81
82
83
84
85 @Override
86 public synchronized E poll() {
87 return queue.poll();
88 }
89
90
91
92
93 @Override
94 public synchronized E remove() {
95 return queue.remove();
96 }
97
98
99
100
101 @Override
102 public synchronized boolean addAll(Collection<? extends E> c) {
103 return queue.addAll(c);
104 }
105
106
107
108
109 @Override
110 public synchronized void clear() {
111 queue.clear();
112 }
113
114
115
116
117 @Override
118 public synchronized boolean contains(Object o) {
119 return queue.contains(o);
120 }
121
122
123
124
125 @Override
126 public synchronized boolean containsAll(Collection<?> c) {
127 return queue.containsAll(c);
128 }
129
130
131
132
133 @Override
134 public synchronized boolean isEmpty() {
135 return queue.isEmpty();
136 }
137
138
139
140
141 @Override
142 public synchronized Iterator<E> iterator() {
143 return queue.iterator();
144 }
145
146
147
148
149 @Override
150 public synchronized boolean remove(Object o) {
151 return queue.remove(o);
152 }
153
154
155
156
157 @Override
158 public synchronized boolean removeAll(Collection<?> c) {
159 return queue.removeAll(c);
160 }
161
162
163
164
165 @Override
166 public synchronized boolean retainAll(Collection<?> c) {
167 return queue.retainAll(c);
168 }
169
170
171
172
173 @Override
174 public synchronized int size() {
175 return queue.size();
176 }
177
178
179
180
181 @Override
182 public synchronized Object[] toArray() {
183 return queue.toArray();
184 }
185
186
187
188
189 @Override
190 public synchronized <T> T[] toArray(T[] a) {
191 return queue.toArray(a);
192 }
193
194
195
196
197 @Override
198 public synchronized boolean equals(Object obj) {
199 return queue.equals(obj);
200 }
201
202
203
204
205 @Override
206 public synchronized int hashCode() {
207 return queue.hashCode();
208 }
209
210
211
212
213 @Override
214 public synchronized String toString() {
215 return queue.toString();
216 }
217 }