Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for initQueue (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  2. 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");
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Nov 13 13:29:22 GMT 2025
    - 9.1K bytes
    - Click Count (0)
Back to Top