- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 370 for Rake (0.36 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
// we allow one second worth of work to go in a burst (i.e. take less than a second) assertTrue(burst <= 1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // but work beyond that must take at least one second assertTrue(afterBurst >= 1000); } } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
@Override public final void run() { /* * Set runner thread before checking isDone(). If we were to check isDone() first, the task * might be cancelled before we set the runner thread. That would make it impossible to * interrupt, yet it will still run, since interruptTask will leave the runner value null, * allowing the CAS below to succeed. */ Thread currentThread = Thread.currentThread();
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/MoreExecutors.java
* completion. * * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}. * * @param executor the executor to modify to make sure it exits when the application is finished * @param terminationTimeout how long to wait for the executor to finish before terminating the * JVM * @param timeUnit unit of time for the time parameter
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
Producer producer = new Producer(q, 1); // producing one, will ask for two Future<?> producerThread = threadPool.submit(producer); producer.beganProducing.await(); // make sure we time out Stopwatch timer = Stopwatch.createStarted(); int drained = drain(q, newArrayList(), 2, 10, MILLISECONDS, interruptibly); assertThat(drained).isAtMost(1);
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/GeneratedMonitorTest.java
} } /** * Generates test cases for the given combination of scenario and timeouts. For methods that take * an explicit timeout value, all of the given timeoutsToUse result in individual test cases. For * methods that do not take an explicit timeout value, a single test case is generated only if the * implicit timeout of that method matches the given timeoutsToUse. For example, enter() is
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 27.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/NavigableSetNavigationTester.java
*/ /* * TODO(cpovirk): or we could make HOLES_FORBIDDEN a feature. Or we could declare that * implementations are permitted to throw IAE if a hole is requested, and we could update * test*Hole to permit IAE. (But might this ignore genuine bugs?) But see the TODO above * testLower, which could make this all unnecessary */ public static Method[] getHoleMethods() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
@Override public int remainingCapacity() { return delegate().remainingCapacity(); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public E take() throws InterruptedException { return delegate().take(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/MavenProject.java
* There is still the issue of having to run the lifecycle in order to find all the compile source roots and resource * directories but I hope to take care of this during the Maven 4.0 release (jvz). * </p> */ public class MavenProject implements Cloneable { private static final Logger LOGGER = LoggerFactory.getLogger(MavenProject.class);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Mar 01 17:18:13 GMT 2024 - 56.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableBiMap.java
} /** * Throws {@link UnsupportedOperationException}. This method is inherited from {@link * ImmutableMap.Builder}, but it does not make sense for bimaps. * * @throws UnsupportedOperationException always * @deprecated This method does not make sense for bimaps and should not be called. * @since 31.1 */ @DoNotCall @Deprecated @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 22.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @Override protected void tearDown() throws Exception { // Make sure we have no waiting threads. latch.countDown(); } /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0)