Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 456 for removeAt (0.04 seconds)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

            override fun runOnce(): Long {
              log += "run@${taskFaker.nanoTime}"
              if (schedules.isNotEmpty()) {
                redQueue.schedule(this, schedules.removeAt(0))
              }
              return delays.removeAt(0)
            }
          }
        redQueue.schedule(task, 100.µs)
    
        taskFaker.advanceUntil(0.µs)
        assertThat(log).isEmpty()
    
        taskFaker.advanceUntil(100.µs)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 23K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

        }
      }
    
      // Returned from removeAt() to iterator.remove()
      private static final class MoveDesc<E> {
        final E toTrickle;
        final E replaced;
    
        MoveDesc(E toTrickle, E replaced) {
          this.toTrickle = toTrickle;
          this.replaced = replaced;
        }
      }
    
      /** Removes and returns the value at {@code index}. */
      private E removeAndGet(int index) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 33.9K bytes
    - Click Count (0)
  3. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

          }
    
          return result
        } finally {
          peekedHeader = null
          limit = pushedLimit
          constructed = pushedConstructed
          if (name != null) path.removeAt(path.size - 1)
        }
      }
    
      /**
       * Execute [block] with a new namespace for type hints. Type hints from the enclosing type are no
       * longer usable by the current type's members.
       */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  4. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        E x = items[takeIndex];
        items[takeIndex] = null;
        takeIndex = inc(takeIndex);
        --count;
        return x;
      }
    
      /**
       * Utility for remove and iterator.remove: Delete item at position i. Call only when occupying
       * monitor.
       */
      void removeAt(int i) {
        E[] items = this.items;
        // if removing front item, just advance
        if (i == takeIndex) {
          items[takeIndex] = null;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        assertTrue("Could not remove larry", mmHeap.remove("larry"));
        assertEquals(6, mmHeap.size());
        assertFalse("heap contains larry which has been removed", mmHeap.contains("larry"));
        assertTrue("heap does not contain sergey", mmHeap.contains("sergey"));
        assertTrue("Could not remove larry", mmHeap.removeAll(Lists.newArrayList("sergey", "eric")));
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

          } else {
            readyQueues.remove(taskQueue)
          }
        }
    
        if (coordinatorWaiting) {
          backend.coordinatorNotify(this@TaskRunner)
        } else {
          startAnotherThread()
        }
      }
    
      private fun beforeRun(task: Task) {
        assertLockHeld()
    
        task.nextExecuteNanoTime = -1L
        val queue = task.queue!!
        queue.futureTasks.remove(task)
        readyQueues.remove(queue)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 30 11:30:11 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

          override fun runOnce(): Long = closeConnections(System.nanoTime())
        }
    
      /**
       * Holding the lock of the connection being added or removed when mutating this, and check its
       * [RealConnection.noNewExchanges] property. This defends against races where a connection is
       * simultaneously adopted and removed.
       */
      private val connections = ConcurrentLinkedQueue<RealConnection>()
    
      init {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      private fun startNextTask(): SerialTask? {
        taskRunner.assertLockHeld()
    
        val index = serialTaskQueue.indexOfFirst { it.isReady() }
        if (index == -1) return null
    
        val nextTask = serialTaskQueue.removeAt(index)
        currentTask = nextTask
        contextSwitchCount++
        nextTask.start()
        return nextTask
      }
    
      private interface SerialTask {
        /** Returns true if this task is ready to start. */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        val calls = connection.calls
        val index = calls.indexOfFirst { it.get() == this@RealCall }
        check(index != -1)
    
        calls.removeAt(index)
        this.connection = null
    
        if (calls.isEmpty()) {
          connection.idleAtNs = System.nanoTime()
          if (connectionPool.connectionBecameIdle(connection)) {
            return connection.socket()
          }
        }
    
        return null
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/InferenceStrategy.java

            // First apply limited inference (child elements) - this removes matching child groupId/version
            hasChanges |= trimParentElementLimited(context, root, parentElement);
    
            // Only remove parent elements if the parent is in the same reactor (not external)
            if (isParentInReactor(parentElement, pomMap, context)) {
                // Remove parent groupId if child has no explicit groupId
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 27.6K bytes
    - Click Count (0)
Back to Top