- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 98 for finish (0.22 sec)
-
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/CollectorTester.java
if (collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)) { @SuppressWarnings("unchecked") // `R` and `A` match for an `IDENTITY_FINISH` R result = (R) finalAccum; assertEquivalent(expectedResult, result); } assertEquivalent(expectedResult, collector.finisher().apply(finalAccum)); } } private void assertEquivalent(R expected, R actual) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 6.5K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. * * <p>Caches loaded by a {@link CacheLoader} will call {@link CacheLoader#load} to load new values
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/math/LinearTransformation.java
public abstract class LinearTransformation { /** * Start building an instance which maps {@code x = x1} to {@code y = y1}. Both arguments must be * finite. Call either {@link LinearTransformationBuilder#and} or {@link * LinearTransformationBuilder#withSlope} on the returned object to finish building the instance. */ public static LinearTransformationBuilder mapping(double x1, double y1) { checkArgument(isFinite(x1) && isFinite(y1));
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 17:02:53 GMT 2023 - 9.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/LineBufferTest.java
int off = 0; while (off < chars.length) { int len = Math.min(chars.length, off + chunk) - off; lineBuf.add(chars, off, len); off += len; } lineBuf.finish(); return lines; } private static List<String> readUsingJava(String input, int chunk) throws IOException { BufferedReader r = new BufferedReader(getChunkedReader(input, chunk));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
*/ RecordingRunnable earlyListener = new RecordingRunnable(); listenable.addListener(earlyListener, directExecutor()); input.allowGetToComplete.countDown(); // Now give the get() thread time to finish: assertTrue(earlyListener.wasRun.await(1, SECONDS)); // Now test an additional addListener call, which will be run in-thread: RecordingRunnable lateListener = new RecordingRunnable();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
} /** * Returns a future that delegates to this future but will finish early (via a {@link * TimeoutException} wrapped in an {@link ExecutionException}) if the specified timeout expires. * If the timeout expires, not only will the output future finish, but also the input future * ({@code this}) will be cancelled and interrupted. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
guava/src/com/google/common/cache/LoadingCache.java
* * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. * * <p>Caches loaded by a {@link CacheLoader} will call {@link CacheLoader#load} to load new values
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/LineBufferTest.java
int off = 0; while (off < chars.length) { int len = Math.min(chars.length, off + chunk) - off; lineBuf.add(chars, off, len); off += len; } lineBuf.finish(); return lines; } private static List<String> readUsingJava(String input, int chunk) throws IOException { BufferedReader r = new BufferedReader(getChunkedReader(input, chunk));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.7K bytes - Viewed (0)