Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,296 for pollable (0.14 sec)

  1. platforms/core-configuration/model-core/src/main/java/org/gradle/util/internal/DeferredUtil.java

        }
    
        public static boolean isNestableDeferred(@Nullable Object value) {
            return value instanceof Callable
                || isKotlinFunction0Deferrable(value);
        }
    
        @Nullable
        public static Object unpackNestableDeferred(@Nullable Object deferred) {
            Object current = deferred;
            while (isNestableDeferred(current)) {
                if (current instanceof Callable) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 12:20:43 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ArrayList<ListenableFuture<@Nullable Void>> results = new ArrayList<>(50_001);
        results.add(
            serializer.submitAsync(
                new AsyncCallable<@Nullable Void>() {
                  @Override
                  public ListenableFuture<@Nullable Void> call() {
                    return settableFuture;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ArrayList<ListenableFuture<@Nullable Void>> results = new ArrayList<>(50_001);
        results.add(
            serializer.submitAsync(
                new AsyncCallable<@Nullable Void>() {
                  @Override
                  public ListenableFuture<@Nullable Void> call() {
                    return settableFuture;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  4. platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/CurrentBuildOperationRef.java

            return INSTANCE;
        }
    
        @Nullable
        public BuildOperationRef get() {
            return ref.get();
        }
    
        @Nullable
        public OperationIdentifier getId() {
            BuildOperationRef operationState = get();
            return operationState == null ? null : operationState.getId();
        }
    
        @Nullable
        public OperationIdentifier getParentId() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:36 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Callable<@Nullable Void> cancelRunnable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
                return null;
              }
            };
        Callable<@Nullable Void> setFutureCompleteSuccessfullyRunnable =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/UncheckedException.java

        }
    
        /**
         * Calls the given callable converting any thrown exception to an unchecked exception via {@link UncheckedException#throwAsUncheckedException(Throwable)}
         *
         * @param callable The callable to call
         * @param <T> Callable's return type
         * @return The value returned by {@link Callable#call()}
         */
        @Nullable
        public static <T> T uncheckedCall(Callable<T> callable) {
            try {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jun 10 14:28:48 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

        final CountDownLatch exitLatch = new CountDownLatch(1);
        final TrustedListenableFutureTask<@Nullable Void> task =
            TrustedListenableFutureTask.create(
                new Callable<@Nullable Void>() {
                  @Override
                  public @Nullable Void call() throws Exception {
                    enterLatch.countDown();
                    new CountDownLatch(1).await(); // wait forever
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Callable<@Nullable Void> cancelRunnable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
                return null;
              }
            };
        Callable<@Nullable Void> setFutureCompleteSuccessfullyRunnable =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. platforms/software/signing/src/main/java/org/gradle/plugins/signing/Signature.java

        /**
         * The date of the signature artifact.
         *
         * @see #getDate()
         */
        private Date date;
    
        private Callable<File> toSignGenerator;
    
        private Callable<String> classifierGenerator;
    
        @Nullable
        private Callable<String> nameGenerator;
    
        /**
         * Creates a signature artifact for the given public artifact.
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 12:20:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

        final CountDownLatch exitLatch = new CountDownLatch(1);
        final TrustedListenableFutureTask<@Nullable Void> task =
            TrustedListenableFutureTask.create(
                new Callable<@Nullable Void>() {
                  @Override
                  public @Nullable Void call() throws Exception {
                    enterLatch.countDown();
                    new CountDownLatch(1).await(); // wait forever
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top