Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for callables (0.16 sec)

  1. 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 Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  2. 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)
  3. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                directExecutor());
        for (int i = 0; i < 25_000; i++) {
          serializer.submit(Callables.<Void>returning(null), directExecutor()).cancel(true);
          unused = serializer.submit(Callables.<Void>returning(null), directExecutor());
        }
        ListenableFuture<Integer> stackDepthCheck =
            serializer.submit(
                new Callable<Integer>() {
                  @Override
                  public Integer call() {
    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)
  4. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                directExecutor());
        for (int i = 0; i < 25_000; i++) {
          serializer.submit(Callables.<Void>returning(null), directExecutor()).cancel(true);
          unused = serializer.submit(Callables.<Void>returning(null), directExecutor());
        }
        ListenableFuture<Integer> stackDepthCheck =
            serializer.submit(
                new Callable<Integer>() {
                  @Override
                  public Integer call() {
    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)
  5. 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)
  6. android/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 May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 28.2K bytes
    - Viewed (0)
  7. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/references/KDocReferenceResolver.kt

        }
    
        private fun KtAnalysisSession.collectSymbolsByFqNameInterpretationAsCallableId(
            callableId: CallableId,
            consumer: MutableCollection<KtSymbol>,
        ) {
            when (val classId = callableId.classId) {
                null -> {
                    consumer.addAll(getTopLevelCallableSymbols(callableId.packageName, callableId.callableName))
                }
    
                else -> {
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Fri Apr 19 11:06:47 GMT 2024
    - 22.6K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        CacheTesting.drainRecencyQueues(cache);
        ticker.advance(1, MILLISECONDS);
        assertThat(keySet).containsExactly(2, 3, 4, 5, 6, 7, 8, 9, 0);
    
        // get(K, Callable) doesn't stop 2 from expiring
        Integer unused = cache.get(2, Callables.returning(-2));
        CacheTesting.drainRecencyQueues(cache);
        ticker.advance(1, MILLISECONDS);
        assertThat(keySet).containsExactly(3, 4, 5, 6, 7, 8, 9, 0);
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri Aug 05 17:21:46 GMT 2022
    - 18.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

        return new WrappingExecutorService(service) {
          @Override
          protected <T extends @Nullable Object> Callable<T> wrapTask(Callable<T> callable) {
            return Callables.threadRenaming(callable, nameSupplier);
          }
    
          @Override
          protected Runnable wrapTask(Runnable command) {
            return Callables.threadRenaming(command, nameSupplier);
          }
        };
      }
    
      /**
    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)
  10. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        CacheTesting.drainRecencyQueues(cache);
        ticker.advance(1, MILLISECONDS);
        assertThat(keySet).containsExactly(2, 3, 4, 5, 6, 7, 8, 9, 0);
    
        // get(K, Callable) doesn't stop 2 from expiring
        Integer unused = cache.get(2, Callables.returning(-2));
        CacheTesting.drainRecencyQueues(cache);
        ticker.advance(1, MILLISECONDS);
        assertThat(keySet).containsExactly(3, 4, 5, 6, 7, 8, 9, 0);
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Aug 05 17:21:46 GMT 2022
    - 18.7K bytes
    - Viewed (0)
Back to top