- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for Runnable (1.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
private val busyQueues = mutableListOf<TaskQueue>() /** Queues not in [busyQueues] that have non-empty [TaskQueue.futureTasks]. */ private val readyQueues = mutableListOf<TaskQueue>() private val runnable: Runnable = object : Runnable { override fun run() { var incrementedRunCallCount = false while (true) { val task = ******@****.***ck {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
TaskRunner( object : TaskRunner.Backend { override fun execute( taskRunner: TaskRunner, runnable: Runnable, ) { taskRunner.assertThreadHoldsLock() val queuedTask = RunnableSerialTask(runnable) serialTaskQueue += queuedTask executeCallCount++ isParallel = serialTaskQueue.size > 1 }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
build-logic/buildquality/src/main/kotlin/gradlebuild.arch-test.gradle.kts
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Apr 03 13:29:44 GMT 2024 - 3K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AnonymousClassesFilteringTest.kt
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 1.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
private val dispatcherTest: DispatcherTest, ) : AbstractExecutorService() { private var shutdown: Boolean = false private val calls = mutableListOf<RealCall.AsyncCall>() override fun execute(command: Runnable) { if (shutdown) throw RejectedExecutionException() calls.add(command as RealCall.AsyncCall) } fun assertJobs(vararg expectedUrls: String) { val actualUrls = calls.map { it.request.url.toString() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
cycle_suppress_list.txt
FIELD com.google.common.util.concurrent.AbstractFuture.Listener.executor com.google.common.util.concurrent.ExecutionSequencer.TaskNonReentrantExecutor # ***** FALSE POSITIVES ***** # The Runnable type is so generic that it produces too many false positives. TYPE java.lang.Runnable FIELD com.google.common.base.Converter.reverse FIELD com.google.common.collect.AbstractBiMap.EntrySet.iterator.$.entry com.google.common.collect.AbstractBiMap.EntrySet.iterator.$.next.$
Plain Text - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
private val loggingUncaughtExceptionHandler = UncaughtExceptionHandler { _, throwable -> log.put("uncaught exception: $throwable") } private val threadFactory = ThreadFactory { runnable -> Thread(runnable, "TaskRunnerRealBackendTest").apply { isDaemon = true uncaughtExceptionHandler = loggingUncaughtExceptionHandler } } private val backend = TaskRunner.RealBackend(threadFactory)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
} @JvmStatic fun threadFactory(name: String): ThreadFactory { return object : ThreadFactory { private var nextId = 1 override fun newThread(runnable: Runnable): Thread { return Thread(runnable, "$name-${nextId++}") } } } } fun getEnv(name: String) = System.getenv(name) val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
* This means that if you are doing synchronous calls the network layer will not truly be idle * until every returned [Response] has been closed. */ var idleCallback: Runnable? = null get() = this.withLock { field } set(value) { this.withLock { field = value } } private var executorServiceOrNull: ExecutorService? = null @get:JvmName("executorService")
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/-UtilJvm.kt
@JvmField internal val UTC: TimeZone = TimeZone.getTimeZone("GMT")!! internal fun threadFactory( name: String, daemon: Boolean, ): ThreadFactory = ThreadFactory { runnable -> Thread(runnable, name).apply { isDaemon = daemon } } internal fun HttpUrl.toHostHeader(includeDefaultPort: Boolean = false): String { val host = if (":" in host) { "[$host]" } else {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0)