Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 383 for queues (0.71 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. docs/es/docs/advanced/sub-applications.md

    # Sub Aplicaciones - Mounts
    
    Si necesitas tener dos aplicaciones de **FastAPI** independientes, cada una con su propio OpenAPI independiente y su propia interfaz de docs, puedes tener una aplicación principal y "montar" una (o más) sub-aplicación(es).
    
    ## Montar una aplicación **FastAPI**
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 3K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top