- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for enqueue (0.54 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); queue.addListener(listener, directExecutor()); Multiset<Object> counters = ConcurrentHashMultiset.create(); queue.enqueue(incrementingEvent(counters, listener, 1)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 3));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
ListenerCallQueue<Object> queue = new ListenerCallQueue<>(); queue.addListener(listener, directExecutor()); Multiset<Object> counters = ConcurrentHashMultiset.create(); queue.enqueue(incrementingEvent(counters, listener, 1)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 3));
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
*/ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /** * Enqueues an event to be run on currently known listeners, with a label. * * @param event the callback to execute on {@link #dispatch} * @param label a description of the event to use in the case of an error */ public void enqueue(Event<L> event, String label) { enqueueHelper(event, label);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueueOfferTester.java
public void testOffer_supportedNotPresent() { assertTrue("offer(notPresent) should return true", getQueue().offer(e3())); expectAdded(e3()); } @CollectionFeature.Require({SUPPORTS_ADD, ALLOWS_NULL_VALUES}) public void testOffer_nullSupported() { assertTrue("offer(null) should return true", getQueue().offer(null)); expectAdded((E) null); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java
@CollectionSize.Require(ZERO) public void testPeek_empty() { assertNull("emptyQueue.peek() should return null", getQueue().peek()); expectUnchanged(); } @CollectionSize.Require(ONE) public void testPeek_size1() { assertEquals("size1Queue.peek() should return first element", e0(), getQueue().peek()); expectUnchanged(); } @CollectionFeature.Require(KNOWN_ORDER) @CollectionSize.Require(SEVERAL)
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 2.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java
try { getQueue().remove(); fail("emptyQueue.remove() should throw"); } catch (NoSuchElementException expected) { } expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testRemove_size1() { assertEquals("size1Queue.remove() should return first element", e0(), getQueue().remove()); expectMissing(e0()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java
return QueueTestSuiteBuilder.using( new TestStringQueueGenerator() { @Override public Queue<String> create(String[] elements) { Queue<String> queue = new LinkedList<>(MinimalCollection.of(elements)); return Collections.checkedQueue(queue, String.class); } }) .named("checkedQueue/LinkedList") .withFeatures(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 9.4K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBenchmark.java
queue = (BlockingQueue<String>) constructor.newInstance(capacity); strings = new String[capacity]; for (int i = 0; i < capacity; i++) { strings[i] = String.valueOf(Math.random()); } } @Benchmark void addsAndRemoves(int reps) { int capacity = this.capacity; BlockingQueue<String> queue = this.queue; String[] strings = this.strings;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/base/FinalizableWeakReference.java
/** * Constructs a new finalizable weak reference. * * @param referent to weakly reference * @param queue that should finalize the referent */ protected FinalizableWeakReference(@CheckForNull T referent, FinalizableReferenceQueue queue) { super(referent, queue.queue); queue.cleanUp(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 23 15:09:35 GMT 2023 - 1.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
import java.util.Collection; import java.util.Iterator; import java.util.Queue; import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * Tests for {@link Synchronized#queue} and {@link Queues#synchronizedQueue}. * * @author Kurt Alfred Kluever */ public class SynchronizedQueueTest extends TestCase { protected Queue<String> create() { TestQueue<String> inner = new TestQueue<>();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.7K bytes - Viewed (0)