Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 73 for isHoge (0.08 seconds)

  1. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

              protected void finalize() {
                future.set(null);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_future_cancel() {
        SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object unused =
            new Object() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ForwardingFuture.java

        return delegate().cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate().isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate().isDone();
      }
    
      @Override
      @CanIgnoreReturnValue
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
        return delegate().get();
      }
    
      @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 3.6K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                isInterruptibleRegistered.countDown();
                new CountDownLatch(1).await(); // the interrupt will wake us up
                return "impossible!";
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
                return "";
              }
    
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                isInterruptibleRegistered.countDown();
                new CountDownLatch(1).await(); // the interrupt will wake us up
                return "impossible!";
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
                return "";
              }
    
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        // stop it.
        blockingCallable.waitForStart();
    
        // Give the second task a chance to (incorrectly) start up while the first task is running.
        assertThat(future2.isDone()).isFalse();
    
        // Stop the first task. The second task should then run.
        blockingCallable.stop();
        executor.shutdown();
        assertThat(executor.awaitTermination(10, SECONDS)).isTrue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and
     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
     * complete}. If the computation has already completed when the listener is added, the listener will
     * execute immediately.
     *
     * <p>See the Guava User Guide article on <a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

          }
    
          @Override
          public boolean isCancelled() {
            return input.isCancelled();
          }
    
          @Override
          public boolean isDone() {
            return input.isDone();
          }
    
          @Override
          public O get() throws InterruptedException, ExecutionException {
            return applyTransformation(input.get());
          }
    
          @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  8. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and
     * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
     * complete}. If the computation has already completed when the listener is added, the listener will
     * execute immediately.
     *
     * <p>See the Guava User Guide article on <a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        // stop it.
        blockingCallable.waitForStart();
    
        // Give the second task a chance to (incorrectly) start up while the first task is running.
        assertThat(future2.isDone()).isFalse();
    
        // Stop the first task. The second task should then run.
        blockingCallable.stop();
        executor.shutdown();
        assertThat(executor.awaitTermination(10, SECONDS)).isTrue();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/CombinedFuture.java

        CombinedFutureInterruptibleTask(Executor listenerExecutor) {
          this.listenerExecutor = checkNotNull(listenerExecutor);
        }
    
        @Override
        final boolean isDone() {
          return CombinedFuture.this.isDone();
        }
    
        final void execute() {
          try {
            listenerExecutor.execute(this);
          } catch (RejectedExecutionException e) {
            CombinedFuture.this.setException(e);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.8K bytes
    - Click Count (0)
Back to Top