Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for Aracki (0.13 sec)

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

        val name = lock.withLock { nextQueueName++ }
        return TaskQueue(this, "Q$name")
      }
    
      /**
       * Returns a snapshot of queues that currently have tasks scheduled. The task runner does not
       * necessarily track queues that have no tasks scheduled.
       */
      fun activeQueues(): List<TaskQueue> {
        lock.withLock {
          return busyQueues + readyQueues
        }
      }
    
      fun cancelAll() {
        lock.assertHeld()
    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/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

        )
      }
    
      /**
       * The runner doesn't hold references to its queues! Otherwise we'd need a mechanism to clean them
       * up when they're no longer needed and that's annoying. Instead the task runner only tracks which
       * queues have work scheduled.
       */
      @Test fun activeQueuesContainsOnlyQueuesWithScheduledTasks() {
        redQueue.execute("task one", 100.µs) {
          // Do nothing.
        }
    
    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