Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 334 for Queues (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top