Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for NewQueue (0.29 sec)

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

        lock.assertHeld()
        if (executeCallCount > runCallCount) return // A thread is still starting.
    
        executeCallCount++
        backend.execute(this@TaskRunner, runnable)
      }
    
      fun newQueue(): TaskQueue {
        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
    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)
Back to top