Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for cancelFn (0.64 sec)

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

       *
       * <p>This differs from {@link #successfulAsList(ListenableFuture[])} in that it will return a
       * failed future if any of the items fails.
       *
       * <p>Canceling this future will attempt to cancel all the component futures, and if any of the
       * provided futures fails or is canceled, this one is, too.
       *
       * @param futures futures to combine
       * @return a future that provides a list of the results of the component futures
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Futures.java

       *
       * <p>This differs from {@link #successfulAsList(ListenableFuture[])} in that it will return a
       * failed future if any of the items fails.
       *
       * <p>Canceling this future will attempt to cancel all the component futures, and if any of the
       * provided futures fails or is canceled, this one is, too.
       *
       * @param futures futures to combine
       * @return a future that provides a list of the results of the component futures
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 64.1K bytes
    - Viewed (0)
  3. src/cmd/go/internal/script/cmds.go

    			return startCommand(s, name, path, args[1:], cancel, waitDelay)
    		})
    }
    
    func startCommand(s *State, name, path string, args []string, cancel func(*exec.Cmd) error, waitDelay time.Duration) (WaitFunc, error) {
    	var (
    		cmd                  *exec.Cmd
    		stdoutBuf, stderrBuf strings.Builder
    	)
    	for {
    		cmd = exec.CommandContext(s.Context(), path, args...)
    		if cancel == nil {
    			cmd.Cancel = nil
    		} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        step2Waiter.awaitStarted();
    
        // Everything should still be open.
        assertStillOpen(closeable1, closeable2, closeable3, closeable4);
    
        // Cancel step 3, resume step 2, and pause in step 4.
        assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue();
        step2Waiter.awaitReturned();
        step4Waiter.awaitStarted();
    
        // Step 1 is not cancelled because it was done.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:37:15 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

              // Note: The only way this CAS could fail is if cancel() has raced with us. That is ok.
              boolean unused = ATOMIC_HELPER.casValue(this, valueToSet, failure);
            }
            return true;
          }
          localValue = value; // we lost the cas, fall through and maybe cancel
        }
        // The future has already been set to something. If it is cancellation we should cancel the
        // incoming future.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFuture.java

              // Note: The only way this CAS could fail is if cancel() has raced with us. That is ok.
              boolean unused = ATOMIC_HELPER.casValue(this, valueToSet, failure);
            }
            return true;
          }
          localValue = value; // we lost the cas, fall through and maybe cancel
        }
        // The future has already been set to something. If it is cancellation we should cancel the
        // incoming future.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (0)
  7. 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.");
                  }
                }
              });
          try {
            future.get();
          } catch (Throwable t) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  8. .github/workflows/ci.yml

                java: 21
                root-pom: pom.xml
        runs-on: ${{ matrix.os }}
        env:
          ROOT_POM: ${{ matrix.root-pom }}
        steps:
          # Cancel any previous runs for the same branch that are still running.
          - name: 'Cancel previous runs'
            uses: styfle/cancel-workflow-action@85880fa0301c86cca9da44039ee3bb12d3bedbfa # 0.12.1
            with:
              access_token: ${{ github.token }}
          - name: 'Check out repository'
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 17 16:25:39 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
Back to top