Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 310 for Loop (0.05 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      protected void startUp() throws Exception {}
    
      /**
       * Run the service. This method is invoked on the execution thread. Implementations must respond
       * to stop requests. You could poll for lifecycle changes in a work loop:
       *
       * <pre>
       *   public void run() {
       *     while ({@link #isRunning()}) {
       *       // perform a unit of work
       *     }
       *   }
       * </pre>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        // We need to wait for the runner to exit.  It used to be that the runner would get stuck in the
        // busy loop when interrupt threw.
        runner.join(SECONDS.toMillis(10));
      }
    
      static final class BrokenChannel extends AbstractInterruptibleChannel {
        @Override
        protected void implCloseChannel() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

      TensorHandlePtr combined_value = CreatePerDeviceValues(
          context.get(), in_components, device_name, status.get());
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
    
      // Loop to make synchronization failures more deterministic
      for (int i = 0; i < 100; ++i) {
        TensorHandlePtr multiply_result(
            Multiply(context.get(), combined_value.get(), combined_value.get(),
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Jul 10 07:18:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  4. tensorflow/c/c_api_function_test.cc

      // Inputs to the while loop and the function as a whole
      TF_Operation* feed1 = Placeholder(func_graph_, s_, "feed1");
      TF_Operation* feed2 = Placeholder(func_graph_, s_, "feed2");
    
      // Outputs of the while loop corresponding to the two inputs above
      // The first one will the function's output
      std::vector<TF_Output> outputs;
    
      // Add while loop to func_graph_
      {
        // The inputs to the while loop
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Jul 20 22:08:54 UTC 2023
    - 63.6K bytes
    - Viewed (0)
  5. cmd/leak-detect_test.go

    }
    
    // DetectLeak - Creates a snapshot of runtime stack and compares it with the initial stack snapshot.
    func (initialSnapShot LeakDetect) DetectLeak(t TestErrHandler) {
    	if t.Failed() {
    		return
    	}
    	// Loop, waiting for goroutines to shut down.
    	// Wait up to 5 seconds, but finish as quickly as possible.
    	deadline := UTCNow().Add(leakDetectDeadline * time.Second)
    	for {
    		// get sack snapshot of relevant go routines.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/Interners.java

            if (sneaky == null) {
              return sample;
            } else {
              /* Someone beat us to it! Trying again...
               *
               * Technically this loop not guaranteed to terminate, so theoretically (extremely
               * unlikely) this thread might starve, but even then, there is always going to be another
               * thread doing progress here.
               */
            }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 13 14:30:51 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/math/QuantilesAlgorithm.java

                high--;
              } while (array[high] > partition);
              if (high < low) {
                break; // Pointers crossed. Partitioning complete.
              }
              swap(array, low, high); // End of innermost loop.
            }
            array[from + 1] = array[high]; // Insert partitioning element.
            array[high] = partition;
    
            // Continue the partition that contains the kth element.
            if (high >= k) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 01 16:30:37 UTC 2022
    - 7.1K bytes
    - Viewed (0)
  8. helm-releases/minio-5.0.8.tgz

    event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 13 21:49:51 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  9. helm-releases/minio-5.0.9.tgz

    event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 06:23:26 UTC 2023
    - 20.2K bytes
    - Viewed (0)
  10. helm-releases/minio-5.0.10.tgz

    event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 27 00:05:49 UTC 2023
    - 20.3K bytes
    - Viewed (0)
Back to top