Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 76 for Kistner (0.4 sec)

  1. android/guava/src/com/google/common/cache/RemovalListener.java

     * shared resources.
     *
     * @param <K> the most general type of keys this listener can listen for; for example {@code Object}
     *     if any key is acceptable
     * @param <V> the most general type of values this listener can listen for; for example {@code
     *     Object} if any key is acceptable
     * @author Charles Fry
     * @since 10.0
     */
    @GwtCompatible
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Jun 15 18:00:07 GMT 2021
    - 2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

        super(callable);
      }
    
      ListenableFutureTask(Runnable runnable, @ParametricNullness V result) {
        super(runnable, result);
      }
    
      @Override
      public void addListener(Runnable listener, Executor exec) {
        executionList.add(listener, exec);
      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws TimeoutException, InterruptedException, ExecutionException {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

      }
    
      @Override
      public final State state() {
        return delegate.state();
      }
    
      /** @since 13.0 */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        delegate.addListener(listener, executor);
      }
    
      /** @since 14.0 */
      @Override
      public final Throwable failureCause() {
        return delegate.failureCause();
      }
    
      /** @since 15.0 */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        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());
        assertTrue(listenerLatch.await(5, TimeUnit.SECONDS));
        assertTrue(task.isDone());
    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)
  5. android/guava/src/com/google/common/cache/CacheBuilder.java

          return ticker;
        }
        return recordsTime ? Ticker.systemTicker() : NULL_TICKER;
      }
    
      /**
       * Specifies a listener instance that caches should notify each time an entry is removed for any
       * {@linkplain RemovalCause reason}. Each cache created by this builder will invoke this listener
       * as part of the routine maintenance described in the class documentation above.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        } finally {
          joinPool(e);
        }
      }
    
      private static void assertListenerRunImmediately(ListenableFuture<?> future) {
        CountingRunnable listener = new CountingRunnable();
        future.addListener(listener, directExecutor());
        assertEquals(1, listener.count);
      }
    
      private static final class CountingRunnable implements Runnable {
        int count;
    
        @Override
        public void run() {
    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)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          return sync.wasInterrupted();
        }
    
        /**
         * {@inheritDoc}
         *
         * @since 10.0
         */
        @Override
        public void addListener(Runnable listener, Executor exec) {
          executionList.add(listener, exec);
        }
    
        /**
         * Subclasses should invoke this method to set the result of the computation to {@code value}.
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed May 09 15:17:25 GMT 2018
    - 13.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          return sync.wasInterrupted();
        }
    
        /**
         * {@inheritDoc}
         *
         * @since 10.0
         */
        @Override
        public void addListener(Runnable listener, Executor exec) {
          executionList.add(listener, exec);
        }
    
        /**
         * Subclasses should invoke this method to set the result of the computation to {@code value}.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

            new Thread(() -> latch.countDown()).start();
          }
    
          future.addListener(listenerLatch::countDown, exec);
        }
    
        assertSame(Boolean.TRUE, future.get());
        // Wait for the listener latch to complete.
        listenerLatch.await(500, MILLISECONDS);
    
        exec.shutdown();
        exec.awaitTermination(500, MILLISECONDS);
      }
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

              }
            };
        // Adding the listener to both futures guarantees that newFuture will always be set. Adding to
        // taskFuture guarantees completion if the callable is invoked, and adding to outputFuture
        // propagates cancellation if the callable has not yet been invoked.
        outputFuture.addListener(listener, directExecutor());
        taskFuture.addListener(listener, directExecutor());
    
        return outputFuture;
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
Back to top