Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for ListenableFutureTask (0.11 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

      /**
       * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code
       * Callable}.
       *
       * @param callable the callable task
       * @since 10.0
       */
      public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) {
        return new ListenableFutureTask<>(callable);
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 4.2K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

      private final CountDownLatch listenerLatch = new CountDownLatch(1);
    
      private volatile boolean throwException = false;
    
      private final ListenableFutureTask<Integer> task =
          ListenableFutureTask.create(
              () -> {
                runLatch.countDown();
                taskLatch.await();
                if (throwException) {
                  throw new IllegalStateException("Fail");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

      private final CountDownLatch listenerLatch = new CountDownLatch(1);
    
      private volatile boolean throwException = false;
    
      private final ListenableFutureTask<Integer> task =
          ListenableFutureTask.create(
              () -> {
                runLatch.countDown();
                taskLatch.await();
                if (throwException) {
                  throw new IllegalStateException("Fail");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  4. guava/src/com/google/common/cache/CacheLoader.java

          public V load(K key) throws Exception {
            return loader.load(key);
          }
    
          @Override
          public ListenableFuture<V> reload(K key, V oldValue) {
            ListenableFutureTask<V> task =
                ListenableFutureTask.create(() -> loader.reload(key, oldValue).get());
            executor.execute(task);
            return task;
          }
    
          @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 9.5K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/cache/CacheLoader.java

          public V load(K key) throws Exception {
            return loader.load(key);
          }
    
          @Override
          public ListenableFuture<V> reload(K key, V oldValue) {
            ListenableFutureTask<V> task =
                ListenableFutureTask.create(() -> loader.reload(key, oldValue).get());
            executor.execute(task);
            return task;
          }
    
          @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 9.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

        return new SequentialExecutor(delegate);
      }
    
      /**
       * Creates an {@link ExecutorService} whose {@code submit} and {@code invokeAll} methods submit
       * {@link ListenableFutureTask} instances to the given delegate executor. Those methods, as well
       * as {@code execute} and {@code invokeAny}, are implemented in terms of calls to {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
Back to Top