- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 278 for queue (0.17 sec)
-
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
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (0) -
internal/event/config_test.go
</S3Key> </Filter> <Queue>arn:minio:sqs::1:webhook</Queue> <Event>s3:ObjectCreated:Put</Event> </QueueConfiguration>`) queue2 := &Queue{} if err := xml.Unmarshal(data, queue2); err != nil { panic(err) } testCases := []struct { queue *Queue region string expectedResult ARN }{ {queue1, "eu-west-1", ARN{TargetID{"1", "webhook"}, "eu-west-1"}},
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
/** Runnable is not running and not queued for execution */ IDLE, /** Runnable is not running, but is being queued for execution */ QUEUING, /** runnable has been submitted but has not yet begun execution */ QUEUED, RUNNING, } /** Underlying executor that all submitted Runnable objects are run on. */ private final Executor executor; @GuardedBy("queue")
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
delayNanos: Long, ) { lock.assertHeld() val queue = task.queue!! check(queue.activeTask === task) val cancelActiveTask = queue.cancelActiveTask queue.cancelActiveTask = false queue.activeTask = null busyQueues.remove(queue) if (delayNanos != -1L && !cancelActiveTask && !queue.shutdown) { queue.scheduleAndDecide(task, delayNanos, recurrence = true) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
import java.util.Collection; import java.util.Queue; /** * A non-blocking queue which automatically evicts elements from the head of the queue when * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e., * cyclic buffer or ring buffer). *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 17:52:55 GMT 2023 - 4.6K 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.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 22.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
/** Returns the delay in nanoseconds until the next execution, or -1L to not reschedule. */ abstract fun runOnce(): Long internal fun initQueue(queue: TaskQueue) { if (this.queue === queue) return check(this.queue === null) { "task is in multiple queues" } this.queue = queue } override fun toString(): String = name
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* defined as the <i>least</i> element in the queue according to the queue's comparator. But unlike * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link * #removeLast} are also provided, to act on the <i>greatest</i> element in the queue instead. * * <p>A min-max priority queue can be configured with a maximum size. If so, each time the size of
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 34K bytes - Viewed (0) -
android/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(); } };
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K 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)