Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 550 for nwait (0.05 sec)

  1. docs/de/docs/tutorial/request-files.md

    * `seek(versatz)`: Geht zur Position `versatz` (`int`) in der Datei.
        * Z. B. würde `await myfile.seek(0)` zum Anfang der Datei gehen.
        * Das ist besonders dann nützlich, wenn Sie `await myfile.read()` einmal ausführen und dann diese Inhalte erneut auslesen müssen.
    * `close()`: Schließt die Datei.
    
    Da alle diese Methoden `async`hron sind, müssen Sie sie `await`en („erwarten“).
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  2. docs/pt/docs/tutorial/request_files.md

        * E.g., `await myfile.seek(0)` navegaria para o ínicio do arquivo.
        * Isso é especialmente útil se você executar `await myfile.read()` uma vez e depois precisar ler os conteúdos do arquivo de novo.
    * `close()`: Fecha o arquivo.
    
    Como todos esses métodos são assíncronos (`async`) você precisa esperar ("await") por eles.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  3. clause/locking_test.go

    		},
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate, Options: clause.LockingOptionsNoWait}},
    			"SELECT * FROM `users` FOR UPDATE NOWAIT", nil,
    		},
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate, Options: clause.LockingOptionsSkipLocked}},
    			"SELECT * FROM `users` FOR UPDATE SKIP LOCKED", nil,
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:32:56 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  4. cmd/bucket-metadata-sys.go

    			}
    			sys.RemoveStaleBuckets(diskBuckets)
    
    			for i := range buckets {
    				wait := sleeper.Timer(ctx)
    
    				bucket := buckets[i].Name
    				updated := false
    
    				meta, err := loadBucketMetadata(ctx, sys.objAPI, bucket)
    				if err != nil {
    					internalLogIf(ctx, err, logger.WarningKind)
    					wait() // wait to proceed to next entry.
    					continue
    				}
    
    				sys.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  5. docs/em/docs/tutorial/request-files.md

    * `read(size)`: ✍ `size` (`int`) 🔢/🦹 📁.
    * `seek(offset)`: 🚶 🔢 🧘 `offset` (`int`) 📁.
        * 🤶 Ⓜ., `await myfile.seek(0)` 🔜 🚶 ▶️ 📁.
        * 👉 ✴️ ⚠ 🚥 👆 🏃 `await myfile.read()` 🕐 & ⤴️ 💪 ✍ 🎚 🔄.
    * `close()`: 🔐 📁.
    
    🌐 👫 👩‍🔬 `async` 👩‍🔬, 👆 💪 "⌛" 👫.
    
    🖼, 🔘 `async` *➡ 🛠️ 🔢* 👆 💪 🤚 🎚 ⏮️:
    
    ```Python
    contents = await myfile.read()
    ```
    
    🚥 👆 🔘 😐 `def` *➡ 🛠️ 🔢*, 👆 💪 🔐 `UploadFile.file` 🔗, 🖼:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/Queues.java

       * numElements} elements are not available, it will wait for them up to the specified timeout.
       *
       * @param q the blocking queue to be drained
       * @param buffer where to add the transferred elements
       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
       * @return the number of elements transferred
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

        final CountDownLatch latch = new CountDownLatch(2);
    
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      barrier.await();
                    } catch (Exception e) {
                      throw new AssertionError(e);
                    }
    
                    dispatcher.dispatch(2, integerSubscribers.iterator());
                    latch.countDown();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

        }
        return new ListenableFutureAdapter<>(future, executor);
      }
    
      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
       * future to finish, and when it completes, run the listeners. This implementation will wait on
       * the source future indefinitely, so if the source future never completes, the adapter will never
       * complete either.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

          queue.enqueue(incrementingEvent(counters, listener, 4));
          queue.enqueue(countDownEvent(latch));
          assertEquals(0, counters.size());
          queue.dispatch();
          latch.await();
          assertEquals(multiset(listener, 4), counters);
        } finally {
          service.shutdown();
        }
      }
    
      public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  10. docs/pt/docs/advanced/websockets.md

    ///
    
    ## Aguardar por mensagens e enviar mensagens
    
    Em sua rota WebSocket você pode esperar (`await`) por mensagens e enviar mensagens.
    
    {*../../docs_src/websockets/tutorial001.py hl[48:52]*}
    
    Você pode receber e enviar dados binários, de texto e JSON.
    
    ## Tente você mesmo
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 31 12:20:59 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top