- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 816 for QUEUE (0.05 sec)
-
guava/src/com/google/common/eventbus/Dispatcher.java
// This dispatcher matches the original dispatch behavior of EventBus. /** Per-thread queue of events to dispatch. */ private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { return Queues.newArrayDeque(); } };
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* * @param queue the queue to be wrapped in a synchronized view * @return a synchronized view of the specified queue * @since 14.0 */ public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) { return Synchronized.queue(queue, null); } /** * Returns a synchronized (thread-safe) deque backed by the specified deque. In order to guarantee
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 16K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
/** * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders * elements FIFO (first-in-first-out). The head of the queue is that element that has been * on the queue the longest time. The tail of the queue is that element that has been on * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue * retrieval operations obtain elements at the head of the queue.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueueTest.groovy
def message3 = new ChannelMessage(id1, "message 3") given: queue.queue(message1) queue.queue(message2) queue.queue(message3) when: def messages1 = [] def messages2 = [] queue.getChannel(id1).newEndpoint().take(messages1) queue.getChannel(id2).newEndpoint().take(messages2) then: messages1 == [message1, message3]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally { if (loggingEnabled) { val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs if (completedNormally) { log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/queue/delay.go
// will block until there is room. func DelayQueueBuffer(bufferSize int) DelayQueueOption { return func(queue *delayQueue) { if queue.enqueue != nil { close(queue.enqueue) } queue.enqueue = make(chan *delayTask, bufferSize) } } // DelayQueueWorkers sets the number of background worker goroutines await tasks to execute. Effectively the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0) -
test-site/app/models/ContentsCreator.java
continue; } if(url.startsWith("http")) { queue.add(url); } else if(url.startsWith("//")) { queue.add(schema + ":" + url); } else if(url.startsWith("/")) { queue.add(schema + "://" + host + url); } else { queue.add(originUri + '/' + url); } } }
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Fri Nov 06 08:48:32 UTC 2015 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueue.java
public MultiEndPointQueue getChannel(ChannelIdentifier channel) { MultiEndPointQueue queue = channels.get(channel); if (queue == null) { queue = new MultiEndPointQueue(lock); channels.put(channel, queue); initializer.onQueueAdded(queue); } return queue; } public void queue(InterHubMessage message) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.4K bytes - Viewed (0) -
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));
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 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));
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0)