Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for coordinatorNotify (0.19 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

            readyQueues.addIfAbsent(taskQueue)
          } else {
            readyQueues.remove(taskQueue)
          }
        }
    
        if (coordinatorWaiting) {
          backend.coordinatorNotify(this@TaskRunner)
        } else {
          startAnotherThread()
        }
      }
    
      private fun beforeRun(task: Task) {
        lock.assertHeld()
    
        task.nextExecuteNanoTime = -1L
    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)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

              serialTaskQueue += queuedTask
              executeCallCount++
              isParallel = serialTaskQueue.size > 1
            }
    
            override fun nanoTime() = nanoTime
    
            override fun coordinatorNotify(taskRunner: TaskRunner) {
              taskRunner.assertThreadHoldsLock()
              check(waitingCoordinatorTask != null)
    
              // Queue a task to resume the waiting coordinator.
              serialTaskQueue +=
    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)
Back to top