ForwardingBlockingQueue.java
1.42 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package com.google.common.util.concurrent;
import com.google.common.collect.ForwardingQueue;
import java.util.Collection;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
public abstract class ForwardingBlockingQueue<E>
extends ForwardingQueue<E>
implements BlockingQueue<E>
{
protected abstract BlockingQueue<E> delegate();
public int drainTo(Collection<? super E> paramCollection)
{
return delegate().drainTo(paramCollection);
}
public int drainTo(Collection<? super E> paramCollection, int paramInt)
{
return delegate().drainTo(paramCollection, paramInt);
}
public boolean offer(E paramE, long paramLong, TimeUnit paramTimeUnit)
throws InterruptedException
{
return delegate().offer(paramE, paramLong, paramTimeUnit);
}
public E poll(long paramLong, TimeUnit paramTimeUnit)
throws InterruptedException
{
return (E)delegate().poll(paramLong, paramTimeUnit);
}
public void put(E paramE)
throws InterruptedException
{
delegate().put(paramE);
}
public int remainingCapacity()
{
return delegate().remainingCapacity();
}
public E take()
throws InterruptedException
{
return (E)delegate().take();
}
}
/* Location: /home/merong/decompile/hackery-dex2jar.jar!/com/google/common/util/concurrent/ForwardingBlockingQueue.class
* Java compiler version: 6 (50.0)
* JD-Core Version: 0.7.1
*/