- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 276 for Task (0.14 sec)
-
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
public final class InterruptibleTaskTest extends TestCase { // Regression test for a deadlock where a task could be stuck busy waiting for the task to // transition to DONE public void testInterruptThrows() throws Exception { final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task = new InterruptibleTask<@Nullable Void>() { @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
docs/en/docs/tutorial/background-tasks.md
{!../../../docs_src/background_tasks/tutorial001.py!} ``` ## Add the background task Inside of your *path operation function*, pass your task function to the *background tasks* object with the method `.add_task()`: ```Python hl_lines="14" {!../../../docs_src/background_tasks/tutorial001.py!} ``` `.add_task()` receives as arguments: * A task function to be run in the background (`write_notification`).
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Oct 17 05:59:11 GMT 2023 - 5.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
duration: Long, unit: TimeUnit, ) = apply { actions += { Thread.sleep(unit.toMillis(duration)) } } override fun handle(stream: Stream) { val task = serviceStreamTask(stream) results.add(task) task.run() } /** Returns a task that processes both request and response from [stream]. */ private fun serviceStreamTask(stream: Stream): FutureTask<Void> { return FutureTask<Void> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void testNoOpScheduledExecutor() throws InterruptedException { taskDone = false; Runnable task = new Runnable() { @Override public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, TimeUnit.MILLISECONDS); Thread.sleep(20); assertFalse(taskDone);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
public final class InterruptibleTaskTest extends TestCase { // Regression test for a deadlock where a task could be stuck busy waiting for the task to // transition to DONE public void testInterruptThrows() throws Exception { final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task = new InterruptibleTask<@Nullable Void>() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
} /** * Submits a blocking task for the given {@link Future} to provide {@link ListenableFuture} * functionality. * * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the * returned future will emulate {@link ListenableFuture#addListener} by submitting a task to the * given executor at the first call to {@code addListener}. The task must be started by the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
List<String> events = catcher.getEvents(); assertTrue("No events should be delivered synchronously.", events.isEmpty()); // Now we find the task in our Executor and explicitly activate it. List<Runnable> tasks = executor.getTasks(); assertEquals("One event dispatch task should be queued.", 1, tasks.size()); tasks.get(0).run(); assertEquals("One event should be delivered.", 1, events.size());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.3K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/AbstractBuildScanInfoCollectingService.kt
* 1. Collect cache misses for compilation tasks and publish a `CACHE_MISS` tag for build scan. * 2. Collect failed task paths and display a link which points to the corresponding task in the build scan, like `https://ge.gradle.org/s/xxx/console-log?task=yyy`. */ abstract class AbstractBuildScanInfoCollectingService : BuildService<AbstractBuildScanInfoCollectingService.Params>, OperationCompletionListener { /**
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Aug 11 07:01:27 GMT 2022 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
} @Override public final Future<?> submit(Runnable task) { return delegate.submit(wrapTask(task)); } @Override public final <T extends @Nullable Object> Future<T> submit( Runnable task, @ParametricNullness T result) { return delegate.submit(wrapTask(task), result); } @Override public final <T extends @Nullable Object> List<Future<T>> invokeAll(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
public <T extends @Nullable Object> Future<T> submit(Callable<T> task) { return delegate().submit(task); } @Override public Future<?> submit(Runnable task) { return delegate().submit(task); } @Override public <T extends @Nullable Object> Future<T> submit( Runnable task, @ParametricNullness T result) { return delegate().submit(task, result); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0)