- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 96 for asynchronously (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
* * All event methods must execute fast, without external locking, cannot throw exceptions, * attempt to mutate the event parameters, or be reentrant back into the client. * Any IO - writing to files or network should be done asynchronously. */ @ExperimentalOkHttpApi abstract class ConnectionListener { /** * Invoked as soon as a call causes a connection to be started. */ open fun connectStart( route: Route, call: Call,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* asynchronous only if {@link CacheLoader#reload} was overridden with an asynchronous * implementation. * * <p>Returns without doing anything if another thread is currently loading the value for {@code * key}. If the cache loader associated with this cache performs refresh asynchronously then this * method may return before refresh completes. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
// Already connected. Return it immediately. if (plan.isReady) return ConnectResult(plan) // Already failed? Return it immediately. if (plan is FailedPlan) return plan.result // Connect TCP asynchronously. tcpConnectsInFlight += plan val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}" taskRunner.newQueue().schedule( object : Task(taskName) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
final NoOpService service1 = new NoOpService(); // This service will start service1 when addListener is called. This simulates service1 being // started asynchronously. Service service2 = new Service() { final NoOpService delegate = new NoOpService(); @Override public final void addListener(Listener listener, Executor executor) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* set (including {@linkplain #setFuture set asynchronously}). When a call to this method returns, * the {@code Future} is guaranteed to be {@linkplain #isDone done} <b>only if</b> the call was * accepted (in which case it returns {@code true}). If it returns {@code false}, the {@code * Future} may have previously been set asynchronously, in which case its result may not be known
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
final NoOpService service1 = new NoOpService(); // This service will start service1 when addListener is called. This simulates service1 being // started asynchronously. Service service2 = new Service() { final NoOpService delegate = new NoOpService(); @Override public final void addListener(Listener listener, Executor executor) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* } catch (TimeoutException timeout) { * // stopping timed out * } * } * }); * manager.startAsync(); // start all the services asynchronously * } * } * }</pre> * * <p>This class uses the ServiceManager's methods to start all of its services, to respond to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.h
// re-use a thread. std::vector<std::unique_ptr<DeviceThread>> device_threads_; // A cancellation manager to use if the caller does not provide one. When ops // are executed asynchronously this must outlive the queued op, so it can't be // function-local to Execute. mutable std::unique_ptr<CancellationManager> default_cancellation_manager_; };
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Apr 25 15:21:13 GMT 2023 - 12.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* * All event methods must execute fast, without external locking, cannot throw exceptions, attempt * to mutate the event parameters, or be re-entrant back into the client. Any IO - writing to files * or network should be done asynchronously. */ abstract class EventListener { /** * Invoked as soon as a call is enqueued or executed by a client. In case of thread or stream
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
import org.checkerframework.checker.nullness.qual.Nullable; /** * A step in a pipeline of an asynchronous computation. When the last step in the computation is * complete, some objects captured during the computation are closed. * * <p>A pipeline of {@code ClosingFuture}s is a tree of steps. Each step represents either an * asynchronously-computed intermediate value, or else an exception that indicates the failure or
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0)