- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,059 for Callable (0.23 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
} } private static List<Callable<String>> createTasks(int n) { List<Callable<String>> callables = Lists.newArrayList(); for (int i = 0; i < n; i++) { callables.add(Callables.returning(RESULT_VALUE + i)); } return callables; } private static final class WrappedCallable<T> implements Callable<T> { private final Callable<T> delegate;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
List<Callable<T>> tasks = ImmutableList.of(); List<? extends Future<?>> unused = executor.invokeAll(tasks); } public void testListeningDecorator() throws Exception { ListeningExecutorService service = listeningDecorator(newDirectExecutorService()); assertSame(service, listeningDecorator(service)); List<Callable<String>> callables = ImmutableList.of(Callables.returning("x"));
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-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
private static final String GOOD_CALLABLE_RESULT = "good callable result"; private static final Callable<String> GOOD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirSymbolProviderByJavaPsi.kt
override fun getCallableSymbol(callable: PsiMember): KtCallableSymbol? { if (callable !is PsiMethod && callable !is PsiField) return null val name = callable.name?.let(Name::identifier) ?: return null val containingClass = callable.containingClass ?: return null val classSymbol = getNamedClassSymbol(containingClass) ?: return null
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Oct 10 13:38:00 GMT 2023 - 2.1K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/FakeTickerTest.java
runConcurrentTest( numberOfThreads, new Callable<@Nullable Void>() { @Override public @Nullable Void call() throws Exception { long unused = ticker.read(); return null; } }); assertEquals(incrementByNanos * numberOfThreads, ticker.read()); } /** Runs {@code callable} concurrently {@code numberOfThreads} times. */
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 06 14:40:46 GMT 2024 - 6.3K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
taskDone = false; Callable<Integer> task = new Callable<Integer>() { @Override public Integer call() { taskDone = true; return 6; } }; Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule(task, 10000, TimeUnit.MILLISECONDS); assertTrue("Should run callable immediately", taskDone);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/scopes/FirCallableFilteringScope.kt
baseScope.processAllCallables { callable -> if (isTargetCallable(callable)) { add(callable.name) } } } } override fun getCallableNames(): Set<Name> = cachedCallableNames override fun processFunctionsByName(name: Name, processor: (FirNamedFunctionSymbol) -> Unit) { if (!cachedCallableNames.contains(name)) return
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Oct 10 13:38:00 GMT 2023 - 2K bytes - Viewed (0)