Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for coordinates (0.24 sec)

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

        val latch = CountDownLatch(1)
    
        override fun runOnce(): Long {
          latch.countDown()
          return -1L
        }
      }
    
      /** Adds [task] to run in [delayNanos]. Returns true if the coordinator is impacted. */
      internal fun scheduleAndDecide(
        task: Task,
        delayNanos: Long,
        recurrence: Boolean,
      ): Boolean {
        task.initQueue(this)
    
        val now = taskRunner.backend.nanoTime()
    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)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        // Queue a task to interrupt the waiting coordinator.
        serialTaskQueue +=
          object : SerialTask {
            override fun start() {
              taskRunner.assertThreadHoldsLock()
              waitingCoordinatorInterrupted = true
              val coordinatorTask = waitingCoordinatorTask ?: error("no coordinator waiting")
              currentTask = coordinatorTask
    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)
  3. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

              return readyTask
            }
    
            // Notify the coordinator of a task that's coming up soon.
            coordinatorWaiting -> {
              if (minDelayNanos < coordinatorWakeUpAt - now) {
                backend.coordinatorNotify(this@TaskRunner)
              }
              return null
            }
    
            // No other thread is coordinating. Become the coordinator!
            else -> {
              coordinatorWaiting = true
    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)
  4. docs/contribute/code_of_conduct.md

       strive for transparency within our open source community, and we work closely with upstream
       developers and others in the free software community to coordinate our efforts.
    
     * **Be pragmatic**: Questions are encouraged and should be asked early in the process to avoid
       problems later. Be thoughtful and considerate when seeking out the appropriate forum for your
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 5.1K bytes
    - Viewed (0)
  5. CHANGELOG.md

    
    ## Version 5.0.0-alpha.2
    
    _2021-01-30_
    
    **In this release MockWebServer has a new Maven coordinate and package name.** A longstanding
    problem with MockWebServer has been its API dependency on JUnit 4. We've reorganized things to
    remove that dependency while preserving backwards compatibility.
    
    | Maven Coordinate                                         | Package Name          | Description                       |
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:31:39 GMT 2024
    - 21.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

      @Test fun onlyOneCoordinatorWaitingToStartFutureTasks() {
        // Enqueueing the red task starts a coordinator thread.
        redQueue.execute("red task", 100.µs) {
          log += "red:run@${taskFaker.nanoTime}"
        }
        assertThat(taskFaker.executeCallCount).isEqualTo(1)
    
        // Enqueueing the blue task doesn't need a 2nd coordinator yet.
        blueQueue.execute("blue task", 200.µs) {
          log += "blue:run@${taskFaker.nanoTime}"
        }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 23K bytes
    - Viewed (0)
Back to top