- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for futureTasks (0.15 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
cancelActiveTask = true } var tasksCanceled = false for (i in futureTasks.size - 1 downTo 0) { if (futureTasks[i].cancelable) { taskRunner.logger.taskLog(futureTasks[i], this) { "canceled" } tasksCanceled = true futureTasks.removeAt(i) } } return tasksCanceled } override fun toString(): String = name
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
/** Queues with tasks that are currently executing their [TaskQueue.activeTask]. */ private val busyQueues = mutableListOf<TaskQueue>() /** Queues not in [busyQueues] that have non-empty [TaskQueue.futureTasks]. */ private val readyQueues = mutableListOf<TaskQueue>() private val runnable: Runnable = object : Runnable { override fun run() { var incrementedRunCallCount = false while (true) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
*/ 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]. */ internal var nextExecuteNanoTime = -1L /** Returns the delay in nanoseconds until the next execution, or -1L to not reschedule. */ abstract fun runOnce(): Long internal fun initQueue(queue: TaskQueue) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/CompletionServiceStub.java
import java.util.concurrent.CompletionService; import java.util.concurrent.Future; import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; import org.apache.maven.lifecycle.internal.ProjectSegment; /** */ public class CompletionServiceStub implements CompletionService<ProjectSegment> { List<FutureTask<ProjectSegment>> projectBuildFutureTasks = Collections.synchronizedList(new ArrayList<>());
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false); runNInterruptsTest(times, future, interruptReporter); } private static void runTimedInterruptsTest(int times) throws InterruptedException, ExecutionException, TimeoutException { SettableFuture<String> future = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false); runNInterruptsTest(times, future, interruptReporter); } private static void runTimedInterruptsTest(int times) throws InterruptedException, ExecutionException, TimeoutException { SettableFuture<String> future = SettableFuture.create();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ExclusiveCacheAccessingWorker.java
throw UncheckedException.throwAsUncheckedException(e); } } @Override public <T> T read(Supplier<T> task) { FutureTask<T> futureTask = new FutureTask<T>(task::get); addToQueue(futureTask); try { return futureTask.get(); } catch (ExecutionException e) { throw UncheckedException.throwAsUncheckedException(e.getCause());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 8.8K bytes - Viewed (0)