Home
last modified time | relevance | path

Searched refs:workArray (Results 1 – 1 of 1) sorted by relevance

/tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/
DBatchProcessor.kt36 private val workArray = ArrayDeque<Runnable?>(8192) in <lambda>() constant
48 synchronized(workArray) { in <lambda>()
49 workArray.add(task) in <lambda>()
57 synchronized(workArray) { in <lambda>()
58 next = workArray.poll() in <lambda>()
62 synchronized(workArray) { in <lambda>()
63 next = workArray.poll() in <lambda>()
73 synchronized(workArray) { in <lambda>()
74 remaining = workArray.poll() in <lambda>()