- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 308 for Run (0.18 sec)
-
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* or queued. */ @CheckForNull ExecutionSequencer sequencer; /** * Executor the task was set to run on. Set to null when the task has been queued, run, or * cancelled. */ @CheckForNull Executor delegate; /** * Set before calling delegate.execute(); set to null once run, so that it can be GCed; this
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/anotherpackage/ForwardingWrapperTesterTest.java
public Runnable apply(final Runnable runnable) { return new Runnable() { @Override public void run() { runnable.run(); runnable.run(); } }; } }, "run()", "invoked more than once"); } public void testFailsToForwardParameters() { assertFailure( Adder.class,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 15.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/EquivalenceTester.java
delegate.addRelatedGroup(group); items.addAll(ImmutableList.copyOf(group)); return this; } /** Run tests on equivalence methods, throwing a failure on an invalid test */ @CanIgnoreReturnValue public EquivalenceTester<T> test() { for (int run = 0; run < REPETITIONS; run++) { testItems(); delegate.test(); } return this; } private void testItems() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 25 11:57:12 GMT 2023 - 4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// shutDown or runOneIteration) run concurrently with one another. // TODO(lukes): why don't we use ListenableFuture to sequence things? Then we could drop the // lock. private final ReentrantLock lock = new ReentrantLock(); @WeakOuter class Task implements Runnable { @Override public void run() { lock.lock(); try { /*
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/collect/testing/features/FeatureUtilTest.java
fail("Nobody's meant to actually run this!"); } } @AndroidIncompatible // Android attempts to run directly @NonTesterAnnotation @ExampleDerivedFeature.Require({ExampleDerivedFeature.DERIVED_FEATURE_2}) private static class ExampleDerivedInterfaceTester extends ExampleBaseInterfaceTester { // Exists to test that our framework doesn't run it: @SuppressWarnings("unused")
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 10.4K bytes - Viewed (2) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
* @author Chris Povirk */ final class InterruptionUtil { private static final Logger logger = Logger.getLogger(InterruptionUtil.class.getName()); /** Runnable which will interrupt the target thread repeatedly when run. */ private static final class Interruptenator implements Runnable { private final long everyMillis; private final Thread interruptee; private volatile boolean shouldStop = false;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.4K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
@Override protected void setUp() throws Exception { super.setUp(); exec = Executors.newCachedThreadPool(); task.addListener( new Runnable() { @Override public void run() { listenerLatch.countDown(); } }, directExecutor()); } @Override protected void tearDown() throws Exception { if (exec != null) { exec.shutdown();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/EqualsTester.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Oct 31 19:11:50 GMT 2023 - 6K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
@ElementTypesAreNonnullByDefault public interface ListenableFuture<V extends @Nullable Object> extends Future<V> { /** * Registers a listener to be {@linkplain Executor#execute(Runnable) run} on the given executor. * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone() * complete} or, if the computation is already complete, immediately. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
fakePool.execute( new Runnable() { @Override public void run() { Thread.currentThread().interrupt(); } }); // Run a task that expects that it is not interrupted while it is running. e.execute( new Runnable() { @Override public void run() { assertThat(Thread.currentThread().isInterrupted()).isFalse(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0)