equal
deleted
inserted
replaced
157 |
157 |
158 /** Main lock guarding all access */ |
158 /** Main lock guarding all access */ |
159 final ReentrantLock lock = new ReentrantLock(); |
159 final ReentrantLock lock = new ReentrantLock(); |
160 |
160 |
161 /** Condition for waiting takes */ |
161 /** Condition for waiting takes */ |
|
162 @SuppressWarnings("serial") // Classes implementing Condition may be serializable. |
162 private final Condition notEmpty = lock.newCondition(); |
163 private final Condition notEmpty = lock.newCondition(); |
163 |
164 |
164 /** Condition for waiting puts */ |
165 /** Condition for waiting puts */ |
|
166 @SuppressWarnings("serial") // Classes implementing Condition may be serializable. |
165 private final Condition notFull = lock.newCondition(); |
167 private final Condition notFull = lock.newCondition(); |
166 |
168 |
167 /** |
169 /** |
168 * Creates a {@code LinkedBlockingDeque} with a capacity of |
170 * Creates a {@code LinkedBlockingDeque} with a capacity of |
169 * {@link Integer#MAX_VALUE}. |
171 * {@link Integer#MAX_VALUE}. |