- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for remainingCapacity (0.14 seconds)
-
guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); } public void testNewLinkedBlockingQueueCapacity() { assertThrows(IllegalArgumentException.class, () -> Queues.newLinkedBlockingQueue(0)); assertEquals(1, Queues.newLinkedBlockingQueue(1).remainingCapacity());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* * <p>Note that you cannot always tell if an attempt to insert an element will succeed by * inspecting {@code remainingCapacity} because it may be the case that another thread is about to * insert or remove an element. */ @CanIgnoreReturnValue @Override public int remainingCapacity() { Monitor monitor = this.monitor; monitor.enter(); try { return items.length - count;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
override fun offer( element: T, timeout: Long, unit: TimeUnit, ) = error("unsupported") override fun take() = error("unsupported") override fun remainingCapacity() = error("unsupported") override fun drainTo(sink: MutableCollection<in T>) = error("unsupported") override fun drainTo( sink: MutableCollection<in T>, maxElements: Int,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11.9K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* * <p>Note that you cannot always tell if an attempt to insert an element will succeed by * inspecting {@code remainingCapacity} because it may be the case that another thread is about to * insert or remove an element. */ @CanIgnoreReturnValue @Override public int remainingCapacity() { Monitor monitor = this.monitor; monitor.enter(); try { return items.length - count;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
* not capacity constrained. * * @return {@code Integer.MAX_VALUE} */ @CanIgnoreReturnValue // pushed down from class to method @Override public int remainingCapacity() { return Integer.MAX_VALUE; } /** * Removes a single instance of the specified element from this queue, if it is present. MoreCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 19K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/EvictingQueueTest.java
assertEquals(3, queue.remainingCapacity()); queue.add("hi"); assertEquals(2, queue.remainingCapacity()); queue.add("hi"); assertEquals(1, queue.remainingCapacity()); queue.add("hi"); assertEquals(0, queue.remainingCapacity()); } public void testEvictingAfterOne() throws Exception { EvictingQueue<String> queue = EvictingQueue.create(1); assertEquals(0, queue.size());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.9K bytes - Click Count (0)