- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 219 for Queues (0.04 sec)
-
guava/src/com/google/common/collect/AbstractMapBasedMultimap.java
* Most Multimap implementations use a List or Set (or even Multiset) for their values, in which * case Multimap equality works as expected. Users who use a Collection type that does not * implement equals(), such as most Queue implementations, will get the same behavior from our * value-collection wrappers (and from Multimap.equals) as from the underlying Collection. */ @SuppressWarnings("UndefinedEquals")
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Nov 17 22:50:48 UTC 2025 - 48.4K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
* **TunnelRequest is gone.** It specified how to connect to an HTTP proxy. OkHttp 2 uses the new `Request` class for this. * **Dispatcher** is a new class that manages the queue of asynchronous calls. It implements limits on total in-flight calls and in-flight calls per host. #### Implementation changes * Support Android `TrafficStats` socket tagging.Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* rate limit itself. * * {@snippet : * class CrawlingService extends AbstractScheduledService { * private Set<Uri> visited; * private Queue<Uri> toCrawl; * protected void startUp() throws Exception { * toCrawl = readStartingUris(); * } * * protected void runOneIteration() throws Exception { * Uri uri = toCrawl.remove();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.7K bytes - Viewed (0) -
docs/smb3-features/06-witness-protocol-design.md
} } ``` ## 9. Performance and Optimization ### 9.1 Witness Event Batching ```java public class WitnessEventBatcher { private final Queue<WitnessNotification> pendingNotifications; private final ScheduledExecutorService scheduler; private final int batchSize = 10; private final long batchTimeout = 100; // 100msRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 42K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
- Sometimes, the scheduler incorrectly placed a pod in the "unschedulable" queue instead of the "backoff" queue. This happened when some plugin previously declared the pod as "unschedulable" and then in a later attempt encounters some other error. Scheduling of that pod then got delayed by up to five minutes, after which periodic flushing moved the pod back into the "active" queue. ([#120334](https://github.com/kubernetes/kubernetes/pull/120334), [@pohly](https://github.com/pohly))...
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Jul 17 07:48:22 UTC 2024 - 466.3K bytes - Viewed (2) -
CHANGELOG/CHANGELOG-1.31.md
Now, when unschedulable Pods are updated, the scheduling queue checks with QueueingHint(s) whether the update may make the pods schedulable, and requeues them to activeQ/backoffQ **only when** at least one QueueingHint(s) return Queue. Action required for custom scheduler plugin developers:
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Wed Nov 12 11:33:21 UTC 2025 - 451.9K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
- Fixes the bug in PodTopologySpread that only happens with QHint enabled,
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Tue Dec 16 18:27:41 UTC 2025 - 448.1K bytes - Viewed (0) -
CHANGELOG.md
* Fix: Handle multiple 1xx responses. * Fix: Address a performance bug in our internal task runner. We had a race condition that could result in it OkHttp starting a thread for each queued task, even when a single thread could run all of them. * Fix: Address a performance bug in `MultipartReader`. We were scanning the entire input streamRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 05 16:02:59 UTC 2025 - 36.2K bytes - Viewed (2) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt
val snapshot = cache["b"]!! snapshot.close() assertThat(cache.edit("d")).isNull() assertThat(taskFaker.isIdle()).isFalse() // On cache misses, no retry job is queued. assertThat(cache["c"]).isNull() assertThat(taskFaker.isIdle()).isFalse() // Let the rebuild complete successfully. filesystem.setFaultyRename(cacheDir / DiskLruCache.JOURNAL_FILE_BACKUP, false)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 59.4K bytes - Viewed (0) -
src/main/resources/fess_indices/_aws/fess.json
"será", "seremos", "seréis", "serán", "sería", "serías", "seríamos", "seríais", "serían", "era", "eras", "éramos", "erais", "eran", "fui", "fuiste", "fue", "fuimos", "fuisteis", "fueron", "fuera", "fueras", "fuéramos", "fuerais", "fueran", "fuese", "fueses", "fuésemos", "fueseis", "fuesen", "siendo", "sido", "tengo", "tienes", "tiene", "tenemos", "tenéis", "tienen", "tenga", "tengas", "tengamos", "tengáis", "tengan", "tendré", "tendrás", "tendrá", "tendremos", "tendréis", "tendrán", "tendría", "tendrías",...
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Jun 14 00:36:40 UTC 2025 - 117.3K bytes - Viewed (0)