Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 483 for Completer (0.05 sec)

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

      /**
       * Returns the value associated with {@code key} in this cache, first loading that value if
       * necessary. No observable state associated with this cache is modified until loading completes.
       *
       * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for
       * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Aug 06 17:12:03 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_test.go

    			name:           "Invalid-Orderchange",
    			expectedErr:    false,
    			expectedUpdate: true,
    		},
    		{
    			meta:           nmeta1,
    			pools:          pools,
    			name:           "Invalid-Completed-Pool-Not-Removed",
    			expectedErr:    false,
    			expectedUpdate: false,
    		},
    		{
    			meta:           nmeta2,
    			pools:          pools,
    			name:           "Correct-Decom-Pending",
    			expectedErr:    false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 01 14:38:46 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/FluentFuture.java

       * computation is {@linkplain java.util.concurrent.Future#isDone() complete} or, if the
       * computation is already complete, immediately.
       *
       * <p>The callback is run on {@code executor}. There is no guaranteed ordering of execution of
       * callbacks, but any callback added through this method is guaranteed to be called once the
       * computation is complete.
       *
       * <p>Example:
       *
       * <pre>{@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       *             complete, the listener runs immediately in that thread.
       *         <li>When a thread attaches a listener to a {@code ListenableFuture} that's
       *             incomplete and the {@code ListenableFuture} later completes normally, the
       *             listener runs in the thread that completes the {@code ListenableFuture}.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  5. docs/bucket/replication/setup_3site_replication.sh

    	echo "verified sitea-> COMPLETED, siteb-> REPLICA"
    fi
    
    if diff -pruN <(./mc stat --no-list --json sitea/bucket/hosts | jq .) <(./mc stat --no-list --json sitec/bucket/hosts | jq .) | grep -q 'COMPLETED\|REPLICA'; then
    	echo "verified sitea-> COMPLETED, sitec-> REPLICA"
    fi
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      }
    
      public void testListeningDecorator_scheduleSuccess() throws Exception {
        final CountDownLatch completed = new CountDownLatch(1);
        ScheduledThreadPoolExecutor delegate =
            new ScheduledThreadPoolExecutor(1) {
              @Override
              protected void afterExecute(Runnable r, Throwable t) {
                completed.countDown();
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  7. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone()
       * complete} or, if the computation is already complete, immediately.
       *
       * <p>There is no guaranteed ordering of execution of listeners, but any listener added through
       * this method is guaranteed to be called once the computation is complete.
       *
       * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone()
       * complete} or, if the computation is already complete, immediately.
       *
       * <p>There is no guaranteed ordering of execution of listeners, but any listener added through
       * this method is guaranteed to be called once the computation is complete.
       *
       * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
       * future to finish, and when it completes, run the listeners. This implementation will wait on
       * the source future indefinitely, so if the source future never completes, the adapter will never
       * complete either.
       *
       * <p>If the delegate future is interrupted or throws an unexpected unchecked exception, the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

        writeHeader(PREFIX_CLEAN, upstreamSize, metadata.size.toLong())
        file!!.channel.force(false)
    
        // This file is complete.
        synchronized(this@Relay) {
          complete = true
        }
    
        upstream?.closeQuietly()
        upstream = null
      }
    
      fun metadata(): ByteString = metadata
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top