- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for coordinatorWait (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
// No other thread is coordinating. Become the coordinator! else -> { coordinatorWaiting = true coordinatorWakeUpAt = now + minDelayNanos try { backend.coordinatorWait(this@TaskRunner, minDelayNanos) } catch (_: InterruptedException) { // Will cause all tasks to exit unless more are scheduled! cancelAll() } finally {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: * * * By yielding in [TaskRunner.Backend.coordinatorWait]. * * By yielding in [BlockingQueue.poll]. * * By completing. */ class TaskFaker : Closeable { @Suppress("NOTHING_TO_INLINE") internal inline fun Any.assertThreadHoldsLock() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->coordinatorNotify(Lokhttp3/internal/concurrent/TaskRunner;)V HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->coordinatorWait(Lokhttp3/internal/concurrent/TaskRunner;J)V HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->execute(Lokhttp3/internal/concurrent/TaskRunner;Ljava/lang/Runnable;)V
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0)