- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 628 for kuwait (0.1 sec)
-
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) -
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) -
cmd/erasure.go
w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { wait := deleteCleanupSleeper.Timer(ctx) removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir)) wait() return nil }) }) }(disk) } wg.Wait() } // nsScanner will start scanning buckets and send updated totals as they are traversed.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K 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) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 22 13:49:09 UTC 2024 - 6.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
te = null; thread = new Thread( this, name ); thread.setDaemon( true ); synchronized (thread) { thread.start(); thread.wait( timeout ); /* wait for doConnect */ switch (state) { case 1: /* doConnect never returned */ state = 0; thread = null;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}. * * @param executor the executor to modify to make sure it exits when the application is finished * @param terminationTimeout how long to wait for the executor to finish before terminating the * JVM
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 44.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/TimeLimiter.java
* @param timeoutDuration with timeoutUnit, the maximum length of time that callers are willing to * wait on each method call to the proxy * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to * wait on each method call to the proxy * @return a time-limiting proxy * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 15.3K bytes - Viewed (0) -
prepare_stmt.go
db.Mux.RUnlock() // wait for other goroutines prepared <-stmt.prepared if stmt.prepareErr != nil { return Stmt{}, stmt.prepareErr } return *stmt, nil } db.Mux.RUnlock() db.Mux.Lock() // double check if stmt, ok := db.Stmts[query]; ok && (!stmt.Transaction || isTransaction) { db.Mux.Unlock() // wait for other goroutines prepared <-stmt.prepared
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:02:05 UTC 2024 - 6.6K bytes - Viewed (0) -
tests/test_dependency_contextvars.py
legacy_request_state_context_var.reset(contextvar_token) @app.middleware("http") async def custom_middleware( request: Request, call_next: Callable[[Request], Awaitable[Response]] ): response = await call_next(request) response.headers["custom"] = "foo" return response @app.get("/user", dependencies=[Depends(set_up_request_state_dependency)]) def get_user():
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Feb 17 12:40:12 UTC 2022 - 1.5K bytes - Viewed (0)