- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 84 for cartel (0.54 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { if (!sync.cancel(mayInterruptIfRunning)) { return false; } executionList.execute(); if (mayInterruptIfRunning) { interruptTask(); } return true;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { if (!sync.cancel(mayInterruptIfRunning)) { return false; } executionList.execute(); if (mayInterruptIfRunning) { interruptTask(); } return true;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception { assertFalse(future.isDone()); assertFalse(future.isCancelled());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/SingleThreadAbstractFutureBenchmark.java
} } return r; } @Benchmark public long timeComplete_Cancel(int reps) throws Exception { long r = 0; List<Facade<Integer>> list = new ArrayList<>(reps); for (int i = 0; i < reps; i++) { final Facade<Integer> localFuture = impl.newFacade(); list.add(localFuture); localFuture.cancel(false); } for (int i = 0; i < reps; i++) { Facade<Integer> facade = list.get(i);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Jul 16 17:22:27 GMT 2019 - 3.6K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create(); Object x = new Object() { @Override protected void finalize() { future.cancel(false); } }; x = null; // Hint to the JIT that x is unreachable
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.4K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_Future_Cancel() { final SettableFuture<@Nullable Void> future = SettableFuture.create(); Object x = new Object() { @Override protected void finalize() { future.cancel(false); } }; x = null; // Hint to the JIT that x is unreachable
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.4K 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) -
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)