- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 550 for nwait (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
docs/pt/docs/advanced/websockets.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Oct 31 12:20:59 UTC 2024 - 5.7K bytes - Viewed (0)