Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 236 for asyncio (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/main/webapp/js/jquery-3.7.1.min.map

    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
Back to top