Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 744 for completer (0.06 seconds)

  1. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  2. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java

                startLatch.countDown(); // Start all threads
                boolean completed = endLatch.await(10, TimeUnit.SECONDS);
                executor.shutdown();
    
                assertTrue(completed, "All threads should complete without deadlock");
                assertEquals(threadCount * operationsPerThread, completedOps.get(), "All operations should complete");
            }
    
            @Test
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 43.7K bytes
    - Click Count (0)
  4. ci/official/utilities/extract_resultstore_links.py

    RESULT_STORE_LINK_RE = re.compile(
        r'^INFO: Streaming build results to: (https://[\w./\-]+)')
    FAILED_BUILD_LINE = 'FAILED: Build did NOT complete successfully'
    BUILD_STATUS_LINE = 'INFO: Build'
    TESTS_FAILED_RE = re.compile(r'^INFO: Build completed, \d+ tests? FAILED')
    BAZEL_COMMAND_RE = re.compile(
        r'(^| )(?P<command>bazel (.*? )?(?P<type>test|build) .+)')
    
    
    class InvokeStatus:
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Wed Nov 08 17:50:27 GMT 2023
    - 10.9K bytes
    - Click Count (0)
  5. android/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:
       *
       * {@snippet :
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  6. docs/bucket/replication/DESIGN.md

    If an object meets replication rules as set in the replication configuration, `X-Amz-Replication-Status` is first set to `PENDING` as the PUT operation completes and replication is queued (unless synchronous replication is in place). After replication is performed, the metadata on the source object version changes to `COMPLETED` or `FAILED` depending on whether replication succeeded. The object version on the target shows `X-Amz-Replication-Status` of `REPLICA`
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        }
    
        return e
      }
    
      /**
       * Complete this call. This should be called once these properties are all false:
       * [requestBodyOpen], [responseBodyOpen], [socketSinkOpen], [socketSourceOpen], and
       * [expectMoreExchanges].
       *
       * This will release the connection if it is still held.
       *
       * It will also notify the listener that the call completed; either successfully or
       * unsuccessfully.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  8. src/test/java/jcifs/smb/CriticalPerformanceTest.java

            double totalTimeMs = (end - start) / 1_000_000.0;
    
            System.out.printf("Overall Performance Test: completed in %.2f ms%n", totalTimeMs);
    
            // Should complete very quickly with all optimizations
            assertTrue(totalTimeMs < 100, "All operations should complete quickly with performance fixes");
    
            pool.close();
        }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.cancel(true);
                  if (!future.isDone()) {
                    errorMessage.set("Cancel call exited before future was complete.");
                  }
                }
              });
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  10. cmd/erasure-server-pool-decom.go

    	type poolInfo struct {
    		position     int
    		completed    bool
    		decomStarted bool // started but not finished yet
    	}
    
    	rememberedPools := make(map[string]poolInfo)
    	for idx, pool := range p.Pools {
    		complete := false
    		decomStarted := false
    		if pool.Decommission != nil {
    			if pool.Decommission.Complete {
    				complete = true
    			}
    			decomStarted = true
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
Back to Top