Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,065 for We (0.17 sec)

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

         *       thread cleared it, we still know that it's not associated with our thread
         *   <li>If this field's value == null because it was associated with our thread and was
         *       cleared, we know that we're not executing inline any more
         * </ul>
         *
         * All the states where thread != currentThread are identical for our purposes, and so even
         * though it's racy, we don't care which of those values we get, so no need to synchronize.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          if (!firstTimeSeen) {
            /*
             * We've seen this, so we've seen its causes, too. No need to re-add them. (There's one case
             * where this isn't true, but we ignore it: If we record an exception, then someone calls
             * initCause() on it, and then we examine it again, we'll conclude that we've seen the whole
             * chain before when in fact we haven't. But this should be rare.)
             */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/hash/LittleEndianByteArray.java

       * @return a long of a concatenated 8 bytes
       */
      static long load64Safely(byte[] input, int offset, int length) {
        long result = 0;
        // Due to the way we shift, we can stop iterating once we've run out of data, the rest
        // of the result already being filled with zeros.
    
        // This loop is critical to performance, so please check HashBenchmark if altering it.
        int limit = Math.min(length, 8);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 9.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
            return toReturn;
          }
    
          @GuardedBy("lock")
          /*
           * The GuardedBy checker warns us that we're not holding cancellationDelegate.lock. But in
           * fact we are holding it because it is the same as this.lock, which we know we are holding,
           * thanks to @GuardedBy above. (cancellationDelegate.lock is initialized to this.lock in the
           * call to `new SupplantableFuture` below.)
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/TempFileCreator.java

            /*
             * We don't *need* to use reflection to access Optional: It's available on all JDKs we
             * support, and Android code won't get this far, anyway, because ProcessHandle is
             * unavailable. But given how much other reflection we're using, we might as well use it
             * here, too, so that we don't need to also suppress an AndroidApiChecker error.
             */
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Oct 06 17:11:11 GMT 2023
    - 12.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

     * </ul>
     *
     * To force selection of our fallback strategies we load {@link AbstractFuture} (and all of {@code
     * com.google.common.util.concurrent}) in degenerate class loaders which make certain platform
     * classes unavailable. Then we construct a test suite so we can run the normal AbstractFutureTest
     * test methods in these degenerate classloaders.
     */
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 16 03:24:50 GMT 2021
    - 6.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/base/AndroidIncompatible.java

     *       under all environments. We could fight this by fully qualifying the annotation, but the
     *       result will be verbose and attention-grabbing.
     *   <li>We need to be careful about how we suppress {@code suite()} methods in {@code common.io}.
     *       The generated suite for {@code FooTest} ends up containing {@code FooTest} itself plus some
     *       other tests. We want to exclude the other tests (which Android can't handle) while
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Jul 07 15:40:13 GMT 2023
    - 3.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/graph/EndpointPairIterator.java

       * visited twice if there is an edge connecting them. To avoid returning duplicate {@link
       * EndpointPair}s, we keep track of the nodes that we have visited. When processing endpoint
       * pairs, we skip if the "other node" is in the visited set, as shown below:
       *
       * <pre>
       * Nodes = {N1, N2, N3, N4}
       *    N2           __
       *   /  \         |  |
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Jul 09 17:31:04 GMT 2021
    - 5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractService.java

          } finally {
            monitor.leave();
          }
        } else {
          // It is possible due to races that we are currently in the expected state even though we
          // timed out. e.g. if we weren't event able to grab the lock within the timeout we would never
          // even check the guard. I don't think we care too much about this use case but it could lead
          // to a confusing error message.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

      @SuppressWarnings("ThreadPriorityCheck") // The cow told me to
      @Override
      public final void run() {
        /*
         * Set runner thread before checking isDone(). If we were to check isDone() first, the task
         * might be cancelled before we set the runner thread. That would make it impossible to
         * interrupt, yet it will still run, since interruptTask will leave the runner value null,
         * allowing the CAS below to succeed.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Sep 29 21:34:48 GMT 2023
    - 9.9K bytes
    - Viewed (0)
Back to top