- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 85 for Ridley (0.3 sec)
-
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.IDLE; import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUED; import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.QUEUING;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
/** Returns the number of idle connections in the pool. */ fun idleConnectionCount(): Int = delegate.idleConnectionCount() /** Returns total number of connections in the pool. */ fun connectionCount(): Int = delegate.connectionCount() internal val connectionListener: ConnectionListener get() = delegate.connectionListener /** Close and remove all idle connections in the pool. */ fun evictAll() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} /** * A callback to be invoked each time the dispatcher becomes idle (when the number of running * calls returns to zero). * * Note: The time at which a [call][Call] is considered idle is different depending on whether it * was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure]
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
if (!inputExhausted) { responseBodyComplete() } closed = true } } companion object { private const val NO_CHUNK_YET = -1L private const val STATE_IDLE = 0 // Idle connections are ready to write request headers. private const val STATE_OPEN_REQUEST_BODY = 1 private const val STATE_WRITING_REQUEST_BODY = 2 private const val STATE_READ_RESPONSE_HEADERS = 3
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/base/Charsets.java
* Contains constant definitions for the six standard {@link Charset} instances, which are * guaranteed to be supported by all Java platform implementations. * * <p>Assuming you're free to choose, note that <b>{@link #UTF_8} is widely preferred</b>. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/StringsExplained#charsets">{@code Charsets}</a>. * * @author Mike Bostock * @since 1.0 */
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 3.8K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
TF_EXCLUSIVE_LOCKS_REQUIRED(execution_mutex_); enum class ExecutionState { kReadyToExecute, kHasResult, kIdle, kShuttingDown, }; tensorflow::mutex execution_mutex_; ExecutionState execution_state_ TF_GUARDED_BY(execution_mutex_) = ExecutionState::kIdle; // Tells the worker thread that there is new work. tensorflow::condition_variable start_execute_;
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Feb 09 07:47:20 GMT 2024 - 25.4K bytes - Viewed (1) -
internal/config/scanner/scanner.go
"github.com/minio/pkg/v2/env" ) // Compression environment variables const ( Speed = "speed" EnvSpeed = "MINIO_SCANNER_SPEED" IdleSpeed = "idle_speed" EnvIdleSpeed = "MINIO_SCANNER_IDLE_SPEED" ExcessVersions = "alert_excess_versions" EnvExcessVersions = "MINIO_SCANNER_ALERT_EXCESS_VERSIONS" ExcessFolders = "alert_excess_folders"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
} @Test fun idleCallbackInvokedWhenIdle() { val idle = AtomicBoolean() dispatcher.idleCallback = Runnable { idle.set(true) } client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://a/2")).enqueue(callback) executor.finishJob("http://a/1") assertThat(idle.get()).isFalse() val ready = CountDownLatch(1) val proceed = CountDownLatch(1)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
api/next/62254.txt
pkg net, type KeepAliveConfig struct #62254 pkg net, type KeepAliveConfig struct, Count int #62254 pkg net, type KeepAliveConfig struct, Enable bool #62254 pkg net, type KeepAliveConfig struct, Idle time.Duration #62254 pkg net, type KeepAliveConfig struct, Interval time.Duration #62254 pkg net, type ListenConfig struct, KeepAliveConfig KeepAliveConfig #62254 pkg syscall (windows-386), const WSAENOPROTOOPT = 10042 #62254
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Feb 20 06:04:31 GMT 2024 - 758 bytes - Viewed (0)