Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewTask (0.14 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

            }
          }
    
          // Don't delegate to schedule() because that enforces shutdown rules.
          val newTask = AwaitIdleTask()
          if (scheduleAndDecide(newTask, 0L, recurrence = false)) {
            taskRunner.kickCoordinator(this)
          }
          return newTask.latch
        }
      }
    
      private class AwaitIdleTask : Task("$okHttpName awaitIdle", cancelable = false) {
        val latch = CountDownLatch(1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/CompactHashSet.java

        Object newTable = CompactHashing.createTable(newCapacity);
        int newMask = newCapacity - 1;
    
        if (targetEntryIndex != UNSET) {
          // Add target first; it must be last in the chain because its entry hasn't yet been created
          CompactHashing.tableSet(newTable, targetHash & newMask, targetEntryIndex + 1);
        }
    
        Object oldTable = requireTable();
        int[] entries = requireEntries();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 24K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/CompactHashSet.java

        Object newTable = CompactHashing.createTable(newCapacity);
        int newMask = newCapacity - 1;
    
        if (targetEntryIndex != UNSET) {
          // Add target first; it must be last in the chain because its entry hasn't yet been created
          CompactHashing.tableSet(newTable, targetHash & newMask, targetEntryIndex + 1);
        }
    
        Object oldTable = requireTable();
        int[] entries = requireEntries();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/MapMakerInternalMap.java

           */
    
          int newCount = count;
          AtomicReferenceArray<E> newTable = newEntryArray(oldCapacity << 1);
          threshold = newTable.length() * 3 / 4;
          int newMask = newTable.length() - 1;
          for (int oldIndex = 0; oldIndex < oldCapacity; ++oldIndex) {
            // We need to guarantee that any existing reads of old Map can
            // proceed. So we cannot yet null out each bin.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

           */
    
          int newCount = count;
          AtomicReferenceArray<E> newTable = newEntryArray(oldCapacity << 1);
          threshold = newTable.length() * 3 / 4;
          int newMask = newTable.length() - 1;
          for (int oldIndex = 0; oldIndex < oldCapacity; ++oldIndex) {
            // We need to guarantee that any existing reads of old Map can
            // proceed. So we cannot yet null out each bin.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/LocalCache.java

           */
    
          int newCount = count;
          AtomicReferenceArray<ReferenceEntry<K, V>> newTable = newEntryArray(oldCapacity << 1);
          threshold = newTable.length() * 3 / 4;
          int newMask = newTable.length() - 1;
          for (int oldIndex = 0; oldIndex < oldCapacity; ++oldIndex) {
            // We need to guarantee that any existing reads of old Map can
            // proceed. So we cannot yet null out each bin.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
Back to top