127 |
|
private final ReentrantLock takeLock = new ReentrantLock(); |
128 |
|
|
129 |
|
/** Wait queue for waiting takes */ |
130 |
+ |
@SuppressWarnings("serial") // Classes implementing Condition may be serializable. |
131 |
|
private final Condition notEmpty = takeLock.newCondition(); |
132 |
|
|
133 |
|
/** Lock held by put, offer, etc */ |
134 |
|
private final ReentrantLock putLock = new ReentrantLock(); |
135 |
|
|
136 |
|
/** Wait queue for waiting puts */ |
137 |
+ |
@SuppressWarnings("serial") // Classes implementing Condition may be serializable. |
138 |
|
private final Condition notFull = putLock.newCondition(); |
139 |
|
|
140 |
|
/** |