Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 444 for Queues (0.04 seconds)

  1. docs/es/docs/deployment/fastapicloud.md

    # FastAPI Cloud { #fastapi-cloud }
    
    Puedes desplegar tu app de FastAPI en [FastAPI Cloud](https://fastapicloud.com) con **un solo comando**; ve y 煤nete a la lista de espera si a煤n no lo has hecho. 馃殌
    
    ## Iniciar sesi贸n { #login }
    
    Aseg煤rate de que ya tienes una cuenta de **FastAPI Cloud** (te invitamos desde la lista de espera 馃槈).
    
    Luego inicia sesi贸n:
    
    <div class="termy">
    
    ```console
    $ fastapi login
    
    You are logged in to FastAPI Cloud 馃殌
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 2K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

        startNs = queue.taskRunner.backend.nanoTime()
        log(task, queue, "starting")
      }
    
      var completedNormally = false
      try {
        val result = block()
        completedNormally = true
        return result
      } finally {
        if (loggingEnabled) {
          val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs
          if (completedNormally) {
            log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        private final BlockingQueue<String> queue;
    
        EnableWrites(BlockingQueue<String> queue, long tMinus) {
          super(tMinus);
          assertFalse(queue.isEmpty());
          assertFalse(queue.offer("shouldBeRejected"));
          this.queue = queue;
        }
    
        @Override
        protected void doAction() {
          assertThat(queue.remove()).isNotNull();
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  4. guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java

        return QueueTestSuiteBuilder.using(
                new TestStringQueueGenerator() {
                  @Override
                  public Queue<String> create(String[] elements) {
                    Queue<String> queue = new LinkedList<>(MinimalCollection.of(elements));
                    return Collections.checkedQueue(queue, String.class);
                  }
                })
            .named("checkedQueue/LinkedList")
            .withFeatures(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 12 16:28:01 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  5. docs/es/docs/advanced/stream-data.md

    {* ../../docs_src/stream_data/tutorial001_py310.py ln[1:23] hl[20,23] *}
    
    FastAPI entregar谩 cada bloque de datos a `StreamingResponse` tal cual, no intentar谩 convertirlo a JSON ni nada parecido.
    
    ### *path operation functions* no async { #non-async-path-operation-functions }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:12:26 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  6. docs/es/docs/advanced/testing-events.md

    Cuando necesitas que `lifespan` se ejecute en tus tests, puedes usar el `TestClient` con un statement `with`:
    
    {* ../../docs_src/app_testing/tutorial004_py310.py hl[9:15,18,27:28,30:32,41:43] *}
    
    
    Puedes leer m谩s detalles sobre ["Ejecutar lifespan en tests en el sitio oficial de documentaci贸n de Starlette."](https://www.starlette.dev/lifespan/#running-lifespan-in-tests)
    
    Para los eventos obsoletos `startup` y `shutdown`, puedes usar el `TestClient` as铆:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 13:41:41 GMT 2026
    - 634 bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

                    }
                }
            }
            return OptionalEntity.empty();
        }
    
        /**
         * Processes the search log queue.
         *
         * @param queue The search log queue.
         */
        protected void processSearchLogQueue(final Queue<SearchLog> queue) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String value = fessConfig.getPurgeByBots();
            String[] botNames;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 29.3K bytes
    - Click Count (0)
  8. cmd/admin-heal-ops.go

    		if serverDebugLog {
    			fmt.Printf("Task in the queue: %#v\n", task)
    		}
    	case <-h.ctx.Done():
    		return nil
    	}
    
    	countOKDrives := func(drives []madmin.HealDriveInfo) (count int) {
    		for _, drive := range drives {
    			if drive.State == madmin.DriveStateOk {
    				count++
    			}
    		}
    		return count
    	}
    
    	// task queued, now wait for the response.
    	select {
    	case res := <-task.respCh:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. docs/es/docs/tutorial/debugging.md

    ## Ejecuta tu c贸digo con tu depurador { #run-your-code-with-your-debugger }
    
    Dado que est谩s ejecutando el servidor Uvicorn directamente desde tu c贸digo, puedes llamar a tu programa de Python (tu aplicaci贸n FastAPI) directamente desde el depurador.
    
    ---
    
    Por ejemplo, en Visual Studio Code, puedes:
    
    * Ir al panel de "Debug".
    * "Add configuration...".
    * Seleccionar "Python".
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 2.6K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt

      }
    
      @Test fun taskFailsWithUncheckedException() {
        queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) {
          log.put("failing task running")
          throw RuntimeException("boom!")
        }
    
        queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) {
          log.put("normal task running")
          return@schedule -1L
        }
    
        queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 3.5K bytes
    - Click Count (0)
Back to Top