- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 516 for _wait (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/smb1/smb1/TestLocking.java
final byte[] buf = new byte[1024]; for (int ii = 0; ii < numIter; ii++) { synchronized (this) { ltime = System.currentTimeMillis(); wait(); } try { final double r = Math.random(); if (r < 0.333) { f.exists();
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 4.2K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close() h.client.Close() } // Wait for messages to be sent... h.wg.Wait() } // New initializes a new logger target which // sends log over http to the specified endpoint func New(config Config) *Target { target := &Target{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
cmd/storage-rest-server.go
if doneCh == nil { return } // Indicate we are ready to write. doneCh <- err // Wait for channel to be closed so we don't race on writes. <-doneCh // Clear so we can be called multiple times without crashing. doneCh = nil } } // waitForHTTPResponse will wait for responses where keepHTTPResponseAlive // has been used. // The returned reader contains the payload.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
cmd/erasure-common.go
// // - Do not consume disks which are being healed // // - Future: skip busy disks return } mu.Lock() newDisks = append(newDisks, disks[i]) mu.Unlock() }() } wg.Wait() return newDisks } func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) { disks := er.getOnlineDisks() // Based on the random shuffling return back randomized disks.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.3K bytes - Click Count (0) -
internal/grid/benchmark_test.go
}, nil })) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload) errFatal(err) // Wait for all to connect // Parallel writes per server. b.Run("bytes", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.5K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
Future<?> possiblyIgnoredError = executorService.submit(executeTask); returnValue += (int) listenerLatch.getCount(); listenerLatch.await(); } return returnValue; } @Benchmark int executeThenAdd_multiThreaded(int reps) throws InterruptedException { Runnable addTask = new Runnable() { @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 15.8K bytes - Click Count (0) -
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
crawler.getCrawlerContext().setMaxAccessCount(maxCount); crawler.getCrawlerContext().setNumOfThread(numOfThread); final String sessionId = crawler.execute(); // Wait for crawler to start running with polling long startTime = System.currentTimeMillis(); while (crawler.crawlerContext.getStatus() != CrawlerStatus.RUNNING && System.currentTimeMillis() - startTime < 5000) {
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Sep 06 04:15:37 GMT 2025 - 12.8K bytes - Click Count (0) -
docs/contribute/concurrency.md
#### Http2Stream This lock guards the internal state of each stream. As above, it is never held for blocking operations. When we need to hold an application thread to block a read, we use wait/notify on this lock. This works because the lock is released while `wait()` is waiting. #### Http2Writer
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
docs/ja/docs/advanced/websockets.md
/// note | 技術詳細 `from starlette.websockets import WebSocket` を使用しても構いません. **FastAPI** は開発者の利便性のために、同じ `WebSocket` を提供します。しかし、こちらはStarletteから直接提供されるものです。 /// ## メッセージの送受信 WebSocketルートでは、 `await` を使ってメッセージの送受信ができます。 {* ../../docs_src/websockets/tutorial001.py hl[48:52] *} バイナリやテキストデータ、JSONデータを送受信できます。 ## 試してみる ファイル名が `main.py` である場合、以下の方法でアプリケーションを実行します。 <div class="termy"> ```consoleCreated: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 7.1K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
synchronized (w) { w.checkException(); while (!w.isReady()) { try { w.wait(); } catch (final InterruptedException ie) { throw new SmbException(dest.getURL().toString(), ie); } }
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 16.6K bytes - Click Count (0)