- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 320 for queue (0.16 sec)
-
src/main/resources/fess_indices/fess_config.thumbnail_queue/thumbnail_queue.json
Shinsuke Sugaya <******@****.***> 1638450896 +0900
Json - Registered: Mon Mar 25 08:04:08 GMT 2024 - Last Modified: Thu Dec 02 13:14:56 GMT 2021 - 359 bytes - Viewed (0) -
src/main/config/es/fess_config_thumbnail_queue.json
Json - Registered: Mon Mar 25 08:04:08 GMT 2024 - Last Modified: Thu Dec 02 13:14:56 GMT 2021 - 903 bytes - Viewed (0) -
src/main/resources/fess_indices/fess_config.thumbnail_queue.json
Shinsuke Sugaya <******@****.***> 1638450896 +0900
Json - Registered: Mon Mar 25 08:04:08 GMT 2024 - Last Modified: Thu Dec 02 13:14:56 GMT 2021 - 173 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
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 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 Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K 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 Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.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 Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 22.5K 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 Mar 22 12:43:11 GMT 2024 - Last Modified: Fri May 12 17:52:55 GMT 2023 - 4.6K 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 Mar 22 12:43:11 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K 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 Mar 22 12:43:11 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0)