- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 236 for asyncio (0.06 sec)
-
docs/changelogs/changelog_3x.md
If your application uses `HttpURLConnection.connect()`, `setFixedLengthStreamingMode()`, or `setChunkedStreamingMode()`, OkHttp will now use a async dispatcher thread to establish the HTTP connection. We don’t expect this change to have any behavior or performance consequences. Regardless, please exercise your `OkUrlFactory` and
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
docs/metrics/v3.md
|-----------------------------------------------|-------------------------------------------------------------------------------------------------------|----------| | `minio_notification_current_send_in_progress` | Number of concurrent async Send calls active to all targets. <br><br>Type: counter | `server` |
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 45.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
AbstractFuture<String> future = setFutureFuture.get(); setFutureSetSuccess.set(currentFuture.get().setFuture(future)); setFutureCompletionSuccess.set(future.set("hello-async-world")); awaitUnchecked(barrier); } }; Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
AbstractFuture<String> future = setFutureFuture.get(); setFutureSetSuccess.set(currentFuture.get().setFuture(future)); setFutureCompletionSuccess.set(future.set("hello-async-world")); awaitUnchecked(barrier); } }; Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
cmd/metrics-v2.go
Description: MetricDescription{ Namespace: minioNamespace, Subsystem: notifySubsystem, Name: "current_send_in_progress", Help: "Number of concurrent async Send calls active to all targets (deprecated, please use 'minio_notify_target_current_send_in_progress' instead)", Type: gaugeMetric, }, Value: float64(nstats.CurrentSendCalls), })
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 133.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
waitUntilClosed(closingFuture); assertStillOpen(closeable1); assertClosed(closeable2, closeable3); } // We don't need to test the happy case for SuccessfulCombiner.call(Async) because it's the same // as Combiner. public void testWhenAllSucceed_call_failedInput() throws Exception { assertFinallyFailsWithException( ClosingFuture.whenAllSucceed(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 75.4K bytes - Viewed (0) -
cmd/storage-rest-server.go
globalLocalSetDrives[endpoint.PoolIdx][endpoint.SetIdx][endpoint.DiskIdx] = storage return true } if createStorage(endpoint) { continue } // Start async goroutine to create storage. go func(endpoint Endpoint) { for { time.Sleep(3 * time.Second) if createStorage(endpoint) { return } } }(endpoint) } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 45.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
int grantedCredits = 0; // if while (curReq != null) { if (curReq.isResponseAsync()) { log.trace("Async"); break; } final CommonServerMessageBlockResponse resp = curReq.getResponse(); if (resp == null) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 69.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.34.md
### Feature - Added 3 new metrics for monitoring async API calls in the scheduler when the `SchedulerAsyncAPICalls` feature gate was enabled: - `scheduler_async_api_call_execution_total`: tracks executed API calls by call type and result (success/error)
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Aug 27 10:36:10 UTC 2025 - 292.8K bytes - Viewed (0) -
src/main/webapp/js/jquery-3.7.1.min.map
aTypes","inspectPrefiltersOrTransports","jqXHR","inspected","seekingTransport","inspect","prefilterOrFactory","dataTypeOrTransport","ajaxExtend","flatOptions","ajaxSettings","active","lastModified","etag","url","isLocal","protocol","processData","async","contentType","accepts","json","responseFields","converters","* text","text html","text json","text xml","ajaxSetup","settings","ajaxPrefilter","ajaxTransport","ajax","transport","cacheURL","responseHeadersString","responseHeaders","timeoutTimer"...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 131.6K bytes - Viewed (0)