- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for queue (0.13 sec)
-
android/guava/src/com/google/common/eventbus/Dispatcher.java
// This dispatcher matches the original dispatch behavior of EventBus. /** Per-thread queue of events to dispatch. */ private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { return Queues.newArrayDeque(); } };
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
/** Returns the delay in nanoseconds until the next execution, or -1L to not reschedule. */ abstract fun runOnce(): Long internal fun initQueue(queue: TaskQueue) { if (this.queue === queue) return check(this.queue === null) { "task is in multiple queues" } this.queue = queue } override fun toString(): String = name
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/EvictingQueueTest.java
assertEquals(0, queue.size()); assertEquals(3, queue.remainingCapacity()); assertTrue(queue.add("one")); assertTrue(queue.add("two")); assertTrue(queue.add("three")); assertEquals("one", queue.element()); assertEquals("one", queue.peek()); assertEquals(3, queue.size()); assertEquals(0, queue.remainingCapacity()); assertTrue(queue.add("four")); assertEquals("two", queue.element());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Feb 19 20:34:55 GMT 2024 - 6.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
import okhttp3.internal.assertNotHeld import okhttp3.internal.okHttpName /** * A set of tasks that are executed in sequential order. * * 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, ) {
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) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally { if (loggingEnabled) { val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs if (completedNormally) { log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
} @Test fun taskFailsWithUncheckedException() { queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(100)) { log.put("failing task running") throw RuntimeException("boom!") } queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(200)) { log.put("normal task running") return@schedule -1L } queue.idleLatch().await(500, TimeUnit.MILLISECONDS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
final L listener; final Executor executor; @GuardedBy("this") final Queue<ListenerCallQueue.Event<L>> waitQueue = Queues.newArrayDeque(); @GuardedBy("this") final Queue<Object> labelQueue = Queues.newArrayDeque(); @GuardedBy("this") boolean isThreadScheduled; PerListenerQueue(L listener, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestStringQueueGenerator.java
import java.util.List; import java.util.Queue; /** * Create queue of strings for tests. * * @author Jared Levy */ @GwtCompatible @ElementTypesAreNonnullByDefault public abstract class TestStringQueueGenerator implements TestQueueGenerator<String> { @Override public SampleElements<String> samples() { return new Strings(); } @Override public Queue<String> create(Object... elements) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 1.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/TestStringQueueGenerator.java
import java.util.List; import java.util.Queue; /** * Create queue of strings for tests. * * @author Jared Levy */ @GwtCompatible @ElementTypesAreNonnullByDefault public abstract class TestStringQueueGenerator implements TestQueueGenerator<String> { @Override public SampleElements<String> samples() { return new Strings(); } @Override public Queue<String> create(Object... elements) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 1.6K bytes - Viewed (0) -
build-logic-commons/module-identity/src/main/kotlin/gradlebuild.module-jar.gradle.kts
val seen = mutableSetOf<ResolvedVariantResult>() val queue = ArrayDeque<DependencyResult>() val rootDependencies = rootComponent.getDependenciesForVariant(rootVariant) seen.add(rootVariant) queue.addAll(rootDependencies) while (queue.isNotEmpty()) { val dependency = when (val result = queue.removeFirst()) { is ResolvedDependencyResult -> result
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Mar 28 20:26:58 GMT 2024 - 4.3K bytes - Viewed (0)