Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Phread (0.15 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

                    }
                  });
          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 86.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          // unpark even though the thread has already removed itself from the list. But even if we did
          // use a CAS, that race would still exist (it would just be ever so slightly smaller).
          Thread w = thread;
          if (w != null) {
            thread = null;
            LockSupport.unpark(w);
          }
        }
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

                    }
                  });
          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 86.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

            // proceed. So we cannot yet null out each bin.
            E head = oldTable.get(oldIndex);
    
            if (head != null) {
              E next = head.getNext();
              int headIndex = head.getHash() & newMask;
    
              // Single node on list
              if (next == null) {
                newTable.set(headIndex, head);
              } else {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 91.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/base/CharMatcher.java

        }
    
        char[] chars = string.toCharArray();
        int spread = 1;
    
        // This unusual loop comes from extensive benchmarking
        OUT:
        while (true) {
          pos++;
          while (true) {
            if (pos == chars.length) {
              break OUT;
            }
            if (matches(chars[pos])) {
              break;
            }
            chars[pos - spread] = chars[pos];
            pos++;
          }
          spread++;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 53.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Sets.java

      }
    
      /**
       * Creates a thread-safe set backed by a hash map. The set is backed by a {@link
       * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees.
       *
       * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The
       * set is serializable.
       *
       * @return a new, empty thread-safe {@code Set}
       * @since 15.0
       */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 77.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/cache/CacheBuilder.java

       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
       * higher value than you need can waste space and time, and a significantly lower value can lead
       * to thread contention. But overestimates and underestimates within an order of magnitude do not
       * usually have much noticeable impact. A value of one permits only one thread to modify the cache
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 51.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Multimaps.java

        for (Map.Entry<? extends V, ? extends K> entry : source.entries()) {
          dest.put(entry.getValue(), entry.getKey());
        }
        return dest;
      }
    
      /**
       * Returns a synchronized (thread-safe) multimap backed by the specified multimap. In order to
       * guarantee serial access, it is critical that <b>all</b> access to the backing multimap is
       * accomplished through the returned multimap.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 86.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/CharMatcher.java

        }
    
        char[] chars = string.toCharArray();
        int spread = 1;
    
        // This unusual loop comes from extensive benchmarking
        OUT:
        while (true) {
          pos++;
          while (true) {
            if (pos == chars.length) {
              break OUT;
            }
            if (matches(chars[pos])) {
              break;
            }
            chars[pos - spread] = chars[pos];
            pos++;
          }
          spread++;
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Fri Feb 09 15:49:48 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

        // A happens-before edge between the writes of these fields and their reads exists, because
        // in order to read these fields, the corresponding write to incompleteOutputCount must have
        // been read.
        private boolean wasCancelled = false;
        private boolean shouldInterrupt = true;
        private final AtomicInteger incompleteOutputCount;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
Back to top