Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 337 for enqueue (0.1 sec)

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java

      public void testRemove_empty() {
        assertThrows(NoSuchElementException.class, () -> getQueue().remove());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(SUPPORTS_REMOVE)
      @CollectionSize.Require(ONE)
      public void testRemove_size1() {
        assertEquals("size1Queue.remove() should return first element", e0(), getQueue().remove());
        expectMissing(e0());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 20:00:30 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java

      public void testPoll_empty() {
        assertNull("emptyQueue.poll() should return null", getQueue().poll());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(SUPPORTS_REMOVE)
      @CollectionSize.Require(ONE)
      public void testPoll_size1() {
        assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll());
        expectMissing(e0());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 20:12:35 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/internal/Finalizer.java

          ReferenceQueue<Object> queue,
          PhantomReference<Object> frqReference) {
        this.queue = queue;
    
        this.finalizableReferenceClassReference = new WeakReference<>(finalizableReferenceClass);
    
        // Keep track of the FRQ that started us so we know when to stop.
        this.frqReference = frqReference;
      }
    
      /** Loops continuously, pulling references off the queue and cleaning them up. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Aug 23 12:54:09 UTC 2023
    - 9.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      private final Executor executor;
    
      @GuardedBy("queue")
      private final Deque<Runnable> queue = new ArrayDeque<>();
    
      /** see {@link WorkerRunningState} */
      @LazyInit
      @GuardedBy("queue")
      private WorkerRunningState workerRunningState = IDLE;
    
      /**
       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      private final Executor executor;
    
      @GuardedBy("queue")
      private final Deque<Runnable> queue = new ArrayDeque<>();
    
      /** see {@link WorkerRunningState} */
      @LazyInit
      @GuardedBy("queue")
      private WorkerRunningState workerRunningState = IDLE;
    
      /**
       * This counter prevents an ABA issue where a thread may successfully schedule the worker, the
       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

      private void growIfNeeded() {
        if (size > queue.length) {
          int newCapacity = calculateNewCapacity();
          Object[] newQueue = new Object[newCapacity];
          arraycopy(queue, 0, newQueue, 0, queue.length);
          queue = newQueue;
        }
      }
    
      /** Returns ~2x the old capacity if small; ~1.5x otherwise. */
      private int calculateNewCapacity() {
        int oldCapacity = queue.length;
        int newCapacity =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/MinMaxPriorityQueue.java

      private void growIfNeeded() {
        if (size > queue.length) {
          int newCapacity = calculateNewCapacity();
          Object[] newQueue = new Object[newCapacity];
          arraycopy(queue, 0, newQueue, 0, queue.length);
          queue = newQueue;
        }
      }
    
      /** Returns ~2x the old capacity if small; ~1.5x otherwise. */
      private int calculateNewCapacity() {
        int oldCapacity = queue.length;
        int newCapacity =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        delayNanos: Long,
      ) {
        lock.assertHeld()
    
        val queue = task.queue!!
        check(queue.activeTask === task)
    
        val cancelActiveTask = queue.cancelActiveTask
        queue.cancelActiveTask = false
        queue.activeTask = null
        busyQueues.remove(queue)
    
        if (delayNanos != -1L && !cancelActiveTask && !queue.shutdown) {
          queue.scheduleAndDecide(task, delayNanos, recurrence = true)
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. src/main/webapp/js/admin/jquery-3.7.1.min.js

    )},prefilters:[function(e,t,n){var r,i,o,a,s,u,l,c,f="width"in t||"height"in t,p=this,d={},h=e.style,g=e.nodeType&&ee(e),v=_.get(e,"fxshow");for(r in n.queue||(null==(a=ce._queueHooks(e,"fx")).unqueued&&(a.unqueued=0,s=a.empty.fire,a.empty.fire=function(){a.unqueued||s()}),a.unqueued++,p.always(function(){p.always(function(){a.unqueued--,ce.queue(e,"fx").length||a.empty.fire()})})),t)if(i=t[r],ft.test(i)){if(delete t[r],o=o||"toggle"===i,i===(g?"hide":"show")){if("show"!==i||!v||void 0===v[r])co...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
  10. src/main/webapp/js/admin/adminlte.min.js

    er"+Ne)===$e?this._options.noTransitionAfterReload?e.addClass("hold-transition").addClass($e).delay(50).queue((function(){n.default(this).removeClass("hold-transition"),n.default(this).dequeue()})):e.addClass($e):this._options.noTransitionAfterReload?e.addClass("hold-transition").removeClass($e).delay(50).queue((function(){n.default(this).removeClass("hold-transition"),n.default(this).dequeue()})):e.removeClass($e)}},t._init=function(){var e=this;this.remember(),this.autoCollapse(),n.default(win...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 45.3K bytes
    - Viewed (0)
Back to top