- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 334 for Queues (0.05 sec)
-
android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import java.util.List; import java.util.ListIterator; import java.util.Locale; import java.util.Map; import java.util.NavigableMap; import java.util.NavigableSet; import java.util.PriorityQueue; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.TreeMap; import java.util.TreeSet; import java.util.UUID;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 21.8K bytes - Viewed (0) -
docs/es/docs/alternatives.md
Estas dos fueron elegidas por ser bastante populares y estables, pero haciendo una búsqueda rápida, podrías encontrar docenas de interfaces de usuario alternativas para OpenAPI (que puedes usar con **FastAPI**). /// ### Frameworks REST para Flask
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 25.4K bytes - Viewed (0) -
docs/es/docs/deployment/https.md
* Los **certificados HTTPS** "certifican" un **cierto dominio**, pero el protocolo y la encriptación ocurren a nivel de TCP, **antes de saber** con cuál dominio se está tratando. * **Por defecto**, eso significaría que solo puedes tener **un certificado HTTPS por dirección IP**. * No importa cuán grande sea tu servidor o qué tan pequeña pueda ser cada aplicación que tengas en él. * Sin embargo, hay una **solución** para esto.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun May 11 13:37:26 UTC 2025 - 13K 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/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} throw firstException!! } /** * Returns non-null if we don't need to wait for the launched result. In such cases, this result * must be processed before whatever is waiting in the queue because we may have already acquired * its connection. */ private fun launchTcpConnect(): ConnectResult? { val plan = when { routePlanner.hasNext() -> { try {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.8K bytes - Viewed (0) -
docs/fr/docs/tutorial/background-tasks.md
Ces outils nécessitent généralement des configurations plus complexes ainsi qu'un gestionnaire de queue de message, comme RabbitMQ ou Redis, mais ils permettent d'exécuter des tâches d'arrière-plan dans différents process, et potentiellement, sur plusieurs serveurs.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Nov 10 17:23:38 UTC 2024 - 5.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
object : Task("$okHttpName ConnectionPool connection closer") { override fun runOnce(): Long = closeConnections(System.nanoTime()) } private fun AddressState.scheduleOpener() { queue.schedule( object : Task("$okHttpName ConnectionPool connection opener") { override fun runOnce(): Long = openConnections(this@scheduleOpener) }, ) } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jun 03 17:10:08 UTC 2025 - 16.1K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.ArrayDeque; import java.util.Arrays; import java.util.Queue; import org.jspecify.annotations.Nullable; /** * Provides utility methods for working with byte arrays and I/O streams. * * @author Chris Nokleberg * @author Colin Decker * @since 1.0 */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 31.1K bytes - Viewed (0) -
src/main/resources/fess_indices/fess/fr/stopwords.txt
était étions étiez étaient fus fut fûmes fûtes furent sois soit soyons soyez soient fusse fusses fût fussions fussiez fussent ayant eu eue eues eus ai as avons avez ont aurai auras aura aurons aurez auront aurais aurait aurions auriez auraient avais avait avions aviez avaient
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Mon Nov 27 12:59:36 UTC 2023 - 977 bytes - Viewed (0) -
cmd/site-replication.go
sm.ActiveWorkers.Max += peer.ActiveWorkers.Max } sm.Queued.Avg.Bytes += peer.Queued.Avg.Bytes sm.Queued.Avg.Count += peer.Queued.Avg.Count sm.Queued.Curr.Bytes += peer.Queued.Curr.Bytes sm.Queued.Curr.Count += peer.Queued.Curr.Count if peer.Queued.Max.Count > sm.Queued.Max.Count { sm.Queued.Max.Bytes = peer.Queued.Max.Bytes sm.Queued.Max.Count = peer.Queued.Max.Count } sm.ReplicaCount += peer.ReplicaCount
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 184.7K bytes - Viewed (0)