Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Kistner (0.55 sec)

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

        void call(L listener);
      }
    
      /**
       * Adds a listener that will be called using the given executor when events are later {@link
       * #enqueue enqueued} and {@link #dispatch dispatched}.
       */
      public void addListener(L listener, Executor executor) {
        checkNotNull(listener, "listener");
        checkNotNull(executor, "executor");
        listeners.add(new PerListenerQueue<>(listener, executor));
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 8.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.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
    - 7.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

        }
    
        @Override
        protected Future<V> delegate() {
          return delegate;
        }
    
        @Override
        public void addListener(Runnable listener, Executor exec) {
          executionList.add(listener, exec);
    
          // When a listener is first added, we run a task that will wait for the delegate to finish,
          // and when it is done will run the listeners.
          if (hasListeners.compareAndSet(false, true)) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        CountingRunnable listener = new CountingRunnable();
    
        future.addListener(listener, directExecutor());
        listener.assertNotRun();
    
        future.set(1);
        listener.assertRun();
      }
    
      public void testListenLaterFailed() {
        CountingRunnable listener = new CountingRunnable();
    
        future.addListener(listener, directExecutor());
        listener.assertNotRun();
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void addListener(Runnable listener, Executor executor) {
        checkNotNull(listener, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
        try {
          executor.execute(listener);
        } catch (Exception e) { // sneaky checked exception
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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 Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 51.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

      // operation in the constructor.
      //
      // 1. In the listener that performs the callback. In this case it is fine since inputFuture is
      //    assigned prior to calling addListener, and addListener happens-before any invocation of the
      //    listener. Notably, this means that 'volatile' is unnecessary to make 'inputFuture' visible
      //    to the listener.
      //
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        CountingRunnable listener = new CountingRunnable();
    
        future.addListener(listener, directExecutor());
        listener.assertNotRun();
    
        future.set(1);
        listener.assertRun();
      }
    
      public void testListenLaterFailed() {
        CountingRunnable listener = new CountingRunnable();
    
        future.addListener(listener, directExecutor());
        listener.assertNotRun();
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
Back to top