- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 94 for cancel (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
} else { afterRanInterruptiblyFailure(error); } } } } private void waitForInterrupt(Thread currentThread) { /* * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet. * Wait for the interrupting thread to set DONE. (See interruptTask().) We want to wait so that
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
return new TrustedListenableFutureTask<>(Executors.callable(runnable, result)); } /* * In certain circumstances, this field might theoretically not be visible to an afterDone() call * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture. * * <p>{@code volatile} is required for j2objc transpiling: * https://developers.google.com/j2objc/guides/j2objc-memory-model#atomicity */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java
assertThatFutureBecomesCancelled(closingFuture.finishToFuture()); } @Override void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) { assertThat(closingFuture.finishToFuture().cancel(false)).isTrue(); waitUntilClosed(closingFuture); futureCancelled.countDown(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
AbstractFutureBenchmarks.awaitWaiting(thread); } switch (state) { case NOT_DONE: break; case FINISHED: f.set(null); break; case CANCELLED: f.cancel(false); break; case FAILED: f.setException(new Exception()); break; default: throw new AssertionError(); } return f; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Jan 17 15:34:54 GMT 2018 - 3K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
AbstractFutureBenchmarks.awaitWaiting(thread); } switch (state) { case NOT_DONE: break; case FINISHED: f.set(null); break; case CANCELLED: f.cancel(false); break; case FAILED: f.setException(new Exception()); break; default: throw new AssertionError(); } return f; }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Jan 17 15:34:54 GMT 2018 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
step2Waiter.awaitStarted(); // Everything should still be open. assertStillOpen(closeable1, closeable2, closeable3, closeable4); // Cancel step 3, resume step 2, and pause in step 4. assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue(); step2Waiter.awaitReturned(); step4Waiter.awaitStarted(); // Step 1 is not cancelled because it was done.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
future = service.schedule(runnable, 5, TimeUnit.MINUTES); future.cancel(true); assertTrue(future.isCancelled()); delegateFuture = (ScheduledFuture<?>) delegateQueue.element(); assertTrue(delegateFuture.isCancelled()); delegateQueue.clear(); future = service.scheduleAtFixedRate(runnable, 5, 5, TimeUnit.MINUTES); future.cancel(true); assertTrue(future.isCancelled());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
* State#RUNNING}. Services that need to cancel startup work can override {@link #doCancelStart}. */ @ForOverride protected abstract void doStop(); /** * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
* structure is not necessarily related to the processing format. * * @since 8.0 */ public static final byte ETB = 23; /** * Cancel: A control character used to indicate that the data with which it is sent is in error or * is to be disregarded. * * @since 8.0 */ public static final byte CAN = 24; /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jul 19 15:43:07 GMT 2021 - 21.6K bytes - Viewed (0)