- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for TaskQueue (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* * Work within queues is not concurrent. This is equivalent to each queue having a dedicated thread * for its work; in practice a set of queues may share a set of threads to save resources. */ class TaskQueue internal constructor( internal val taskRunner: TaskRunner, internal val name: String, ) { internal var shutdown = false /** This queue's currently-executing task, or null if none is currently executing. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt
* * Task Queues * ----------- * * Tasks are bound to the [TaskQueue] they are scheduled in. Each queue is sequential and the tasks * within it never execute concurrently. It is an error to use a task in multiple queues. */ abstract class Task( val name: String, val cancelable: Boolean = true, ) { // Guarded by the TaskRunner. internal var queue: TaskQueue? = null /** Undefined unless this is in [TaskQueue.futureTasks]. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
import java.util.logging.Logger internal inline fun Logger.taskLog( task: Task, queue: TaskQueue, messageBlock: () -> String, ) { if (isLoggable(Level.FINE)) { log(task, queue, messageBlock()) } } internal inline fun <T> Logger.logElapsed( task: Task, queue: TaskQueue, block: () -> T, ): T { var startNs = -1L val loggingEnabled = isLoggable(Level.FINE)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.6K bytes - Viewed (0)