Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 375 for LOOP (0.03 seconds)

  1. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        assertTrue(future1.wasInterrupted());
      }
    
      /**
       * Test the case where the futures are fulfilled prior to constructing the ListFuture. There was a
       * bug where the loop that connects a Listener to each of the futures would die on the last
       * loop-check as done() on ListFuture nulled out the variable being looped over (the list of
       * futures).
       */
      public void testAllAsList_doneFutures() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  2. internal/s3select/csv/reader_contrib_test.go

    	if err != nil {
    		b.Fatalf("Reading init failed with %s", err)
    	}
    	defer r.Close()
    	b.ReportAllocs()
    
    	b.SetBytes(int64(len(f)))
    	var record sql.Record
    	for b.Loop() {
    		r, err = NewReader(io.NopCloser(bytes.NewBuffer(f)), &args)
    		if err != nil {
    			b.Fatalf("Reading init failed with %s", err)
    		}
    		for err == nil {
    			record, err = r.Read(record)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.4K bytes
    - Click Count (0)
  3. cmd/data-scanner.go

    // initDataScanner will start the scanner in the background.
    func initDataScanner(ctx context.Context, objAPI ObjectLayer) {
    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Run the data scanner in a loop
    		for {
    			runDataScanner(ctx, objAPI)
    			duration := max(time.Duration(r.Float64()*float64(scannerCycle.Load())),
    				// Make sure to sleep at least a second to avoid high CPU ticks.
    				time.Second)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  4. cmd/xl-storage-format-v2_test.go

    		b.ReportAllocs()
    		b.ResetTimer()
    		b.SetBytes(855) // number of versions...
    		for b.Loop() {
    			mergeXLV2Versions(8, false, 0, vers...)
    		}
    	})
    
    	b.Run("requested-v1", func(b *testing.B) {
    		b.ReportAllocs()
    		b.ResetTimer()
    		b.SetBytes(855) // number of versions...
    		for b.Loop() {
    			mergeXLV2Versions(8, false, 1, vers...)
    		}
    	})
    
    	b.Run("requested-v2", func(b *testing.B) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  5. CHANGELOG/CHANGELOG-1.8.md

    ## Changelog since v1.8.9
    
    ### Other notable changes
    
    * gce: fixes race condition in ServiceController, where nodes weren't updated in the node sync loop, by updating TargetPools in the ensureExternalLoadBalancer call. ([#58368](https://github.com/kubernetes/kubernetes/pull/58368), [@MrHohn](https://github.com/MrHohn))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Tue Feb 20 15:45:02 GMT 2024
    - 312.2K bytes
    - Click Count (0)
  6. docs/pt/docs/tutorial/stream-json-lines.md

    Você também pode usar funções `def` normais (sem `async`) e usar `yield` da mesma forma.
    
    O FastAPI garantirá que sejam executadas corretamente para não bloquear o event loop.
    
    Como, neste caso, a função não é assíncrona, o tipo de retorno adequado seria `Iterable[Item]`:
    
    {* ../../docs_src/stream_json_lines/tutorial001_py310.py ln[27:30] hl[28] *}
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:13 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

       *       RuntimeException} ({@code get} implementations are discouraged from throwing such
       *       exceptions).
       * </ul>
       *
       * <p>The overall principle is to eliminate all checked exceptions: to loop to avoid {@code
       * InterruptedException}, to pass through {@code CancellationException}, and to wrap any exception
       * from the underlying computation in an {@code UncheckedExecutionException} or {@code
       * ExecutionError}.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  8. docs/de/docs/tutorial/stream-json-lines.md

    Sie können auch normale `def`-Funktionen (ohne `async`) verwenden und `yield` auf die gleiche Weise einsetzen.
    
    FastAPI stellt sicher, dass sie korrekt ausgeführt werden, sodass der Event Loop nicht blockiert wird.
    
    Da die Funktion in diesem Fall nicht async ist, wäre der richtige Rückgabetyp `Iterable[Item]`:
    
    {* ../../docs_src/stream_json_lines/tutorial001_py310.py ln[27:30] hl[28] *}
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:48:21 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  9. RELEASE.md

    *   `tf.distribute`
    
        *   Opened an experimental API, `tf.distribute.experimental.coordinator.get_current_worker_index`, for retrieving the worker index from within a worker, when using parameter server training with a custom training loop.
    
    *   `tf.experimental.dtensor`
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Mon Mar 30 18:31:38 GMT 2026
    - 746.5K bytes
    - Click Count (3)
  10. docs/es/docs/tutorial/server-sent-events.md

    También puedes usar funciones `def` normales (sin `async`), y usar `yield` de la misma manera.
    
    FastAPI se asegurará de ejecutarlo correctamente para que no bloquee el event loop.
    
    Como en este caso la función no es async, el tipo de retorno correcto sería `Iterable[Item]`:
    
    {* ../../docs_src/server_sent_events/tutorial001_py310.py ln[28:31] hl[29] *}
    
    ### Sin tipo de retorno { #no-return-type }
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:12:26 GMT 2026
    - 5K bytes
    - Click Count (0)
Back to Top