Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for initQueue (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt

      internal var nextExecuteNanoTime = -1L
    
      /** Returns the delay in nanoseconds until the next execution, or -1L to not reschedule. */
      abstract fun runOnce(): Long
    
      internal fun initQueue(queue: TaskQueue) {
        if (this.queue === queue) return
    
        check(this.queue === null) { "task is in multiple queues" }
        this.queue = queue
      }
    
      override fun toString(): String = name
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

      /** Adds [task] to run in [delayNanos]. Returns true if the coordinator is impacted. */
      internal fun scheduleAndDecide(
        task: Task,
        delayNanos: Long,
        recurrence: Boolean,
      ): Boolean {
        task.initQueue(this)
    
        val now = taskRunner.backend.nanoTime()
        val executeNanoTime = now + delayNanos
    
        // If the task is already scheduled, take the earlier of the two times.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/entity/UrlQueueImplTest.java

        }
    
        public void test_genericTypeFlexibility() {
            // Test with different generic types
            UrlQueueImpl<Integer> intQueue = new UrlQueueImpl<>();
            intQueue.setId(42);
            assertEquals(Integer.valueOf(42), intQueue.getId());
    
            UrlQueueImpl<String> stringQueue = new UrlQueueImpl<>();
            stringQueue.setId("string-id");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 13 13:29:22 UTC 2025
    - 9.1K bytes
    - Viewed (0)
Back to top