- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 393 for queues (0.04 sec)
-
CHANGELOG/CHANGELOG-1.22.md
- apiserver_flowcontrol_current_r: R(the time of the last change in state of the queues) - apiserver_flowcontrol_dispatch_r: R(the time of the latest request dispatch) - apiserver_flowcontrol_latest_s: S(the request last dispatched) = R(when that request starts executing in the virtual world) - apiserver_flowcontrol_next_s_bounds: min and max next S among non-empty queues
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Tue Dec 13 12:43:45 UTC 2022 - 454.1K 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")
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
/** * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run * or queued. */ @Nullable ExecutionSequencer sequencer; /** * Executor the task was set to run on. Set to null when the task has been queued, run, or * cancelled. */ @Nullable Executor delegate; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 22.1K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
size_t* len); // On success, dequeues a tensor from a TF-managed FifoQueue given by // `tensor_id`, associated with `session`. There must be a graph node named // "fifo_queue_dequeue_<tensor_id>", to be executed by this API call. // Caller must call TF_DeleteTensor() over the returned tensor. If the queue is // empty, this call is blocked. //
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/resources/mapping/queue.json
Shinsuke Sugaya <******@****.***> 1730954650 +0900
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 457 bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
* formally, removes an element {@code e} such that {@code o.equals(e)}, if this queue contains * one or more such elements. Returns {@code true} if and only if this queue contained the * specified element (or equivalently, if this queue changed as a result of the call). * * @param o element to be removed from this queue, if present
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 18.9K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_node_replication_last_minute_queued_bytes` | Total number of bytes queued for replication in the last full minute |
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 43.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.15.md
- Scheduler: added metrics to record the number of pending pods in different queues ([#75501](https://github.com/kubernetes/kubernetes/pull/75501), [@Huang-Wei](https://github.com/Huang-Wei))
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu May 05 13:44:43 UTC 2022 - 278.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/BufferCache.java
queueSize.incrementAndGet(); } } // If queue is full, let the buffer be garbage collected } /** * Get current cache statistics for monitoring * @return formatted statistics string */ public static String getCacheStatistics() { return String.format("BufferCache: queued=%d, max=%d, utilization=%.1f%%", queueSize.get(), MAX_BUFFERS,
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 4.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
checkNotNull(event, "event"); checkNotNull(label, "label"); synchronized (listeners) { for (PerListenerQueue<L> queue : listeners) { queue.add(event, label); } } } /** * Dispatches all events enqueued prior to this call, serially and in order, for every listener. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0)