- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 383 for queues (0.71 sec)
-
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.NavigableMap; import java.util.NavigableSet; import java.util.Optional; import java.util.OptionalDouble; import java.util.OptionalInt; import java.util.OptionalLong; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.UUID; import java.util.concurrent.BlockingDeque;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 21.4K bytes - Viewed (0) -
docs/pt/docs/tutorial/header-param-models.md
<div class="screenshot"> <img src="/img/tutorial/header-param-models/image01.png"> </div> ### Proibindo Cabeçalhos adicionais Em alguns casos de uso especiais (provavelmente não muito comuns), você pode querer **restringir** os cabeçalhos que você quer receber. Você pode usar a configuração dos modelos do Pydantic para proibir (`forbid`) quaisquer campos `extra`: {* ../../docs_src/header_param_models/tutorial002_an_py310.py hl[10] *}
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 2K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
} enc := json.NewEncoder(w) for { select { case ev := <-mergeCh: _, err := w.Write(ev) if err != nil { return } if len(mergeCh) == 0 { // Flush if nothing is queued xhttp.Flush(w) } grid.PutByteBuffer(ev) case <-emptyEventTicker: if err := enc.Encode(struct{ Records []event.Event }{}); err != nil { return } xhttp.Flush(w)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
} else { request } this.newCall(actualRequest).enqueueEventSource(listener) } } } companion object { /** * Enqueues a [Call] and process it as [EventSource] with [listener]. */ @JvmStatic @JvmName("enqueue")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 2.5K bytes - Viewed (0) -
docs/es/docs/tutorial/encoder.md
De la misma manera, esta base de datos no recibiría un modelo de Pydantic (un objeto con atributos), solo un `dict`. Puedes usar `jsonable_encoder` para eso. Recibe un objeto, como un modelo de Pydantic, y devuelve una versión compatible con JSON: {* ../../docs_src/encoder/tutorial001_py310.py hl[4,21] *}
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 1.7K bytes - Viewed (0) -
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 Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
docs/contribute/debug_logging.md
[2020-01-01 00:00:00] << 0x00000003 0 DATA END_STREAM [2020-01-01 00:00:00] << 0x00000000 8 GOAWAY [2020-01-01 00:00:05] << 0x00000000 8 GOAWAY ``` ### Task Runner Logging This logs task enqueues, starts, and finishes. ``` [2020-01-01 00:00:00] Q10000 scheduled after 0 µs: OkHttp ConnectionPool [2020-01-01 00:00:00] Q10000 starting : OkHttp ConnectionPool
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 2.7K bytes - Viewed (0) -
docs/es/docs/advanced/sub-applications.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
/** Available send credits for flow control */ protected final AtomicInteger sendCredits; /** Available receive credits for flow control */ protected final AtomicInteger receiveCredits; /** Queue of pending RDMA work requests */ protected final BlockingQueue<RdmaWorkRequest> pendingRequests; // Connection state /** Current connection state */ protected volatile RdmaConnectionState state;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 8.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
* executor, it should be able to run [the configured maximum][maxRequests] number of calls * concurrently. */ class Dispatcher() { /** * The maximum number of requests to execute concurrently. Above this requests queue in memory, * waiting for the running calls to complete. * * If more than [maxRequests] requests are in flight when this is invoked, those requests will * remain in flight. */ @get:Synchronized
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 8.7K bytes - Viewed (0)