Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 280 for dequeue (0.06 sec)

  1. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      private void enqueueStartingEvent() {
        listeners.enqueue(STARTING_EVENT);
      }
    
      private void enqueueRunningEvent() {
        listeners.enqueue(RUNNING_EVENT);
      }
    
      private void enqueueStoppingEvent(final State from) {
        if (from == State.STARTING) {
          listeners.enqueue(STOPPING_FROM_STARTING_EVENT);
        } else if (from == State.RUNNING) {
          listeners.enqueue(STOPPING_FROM_RUNNING_EVENT);
        } else {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  2. test-site/app/models/ContentsCreator.java

                    continue;
                }
                if(url.startsWith("http")) {
                    queue.add(url);
                } else if(url.startsWith("//")) {
                    queue.add(schema + ":" + url);
                } else if(url.startsWith("/")) {
                    queue.add(schema + "://" + host + url);
                } else {
                    queue.add(originUri + '/' + url);
                }
            }
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Fri Nov 06 08:48:32 UTC 2015
    - 3.7K bytes
    - Viewed (0)
  3. docs/fr/docs/tutorial/path-params-numeric-validations.md

    # Paramètres de chemin et validations numériques
    
    De la même façon que vous pouvez déclarer plus de validations et de métadonnées pour les paramètres de requête avec `Query`, vous pouvez déclarer le même type de validations et de métadonnées pour les paramètres de chemin avec `Path`.
    
    ## Importer Path
    
    Tout d'abord, importez `Path` de `fastapi`, et importez `Annotated` :
    
    {* ../../docs_src/path_params_numeric_validations/tutorial001_an_py310.py hl[1,3] *}
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:32:37 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt

            .heldCertificate(certificate, intermediateCa.certificate)
            .build()
        server.useHttps(serverHandshakeCertificates.sslSocketFactory())
    
        // The request should complete successfully.
        server.enqueue(
          MockResponse.Builder()
            .body("abc")
            .build(),
        )
        val call1 =
          client.newCall(
            Request.Builder()
              .url(server.url("/"))
              .build(),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java

          .build();
    
      public void run() throws Exception {
        Request washingtonPostRequest = new Request.Builder()
            .url("https://www.washingtonpost.com/")
            .build();
        client.newCall(washingtonPostRequest).enqueue(new Callback() {
          @Override public void onFailure(Call call, IOException e) {
          }
    
          @Override public void onResponse(Call call, Response response) throws IOException {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 16 23:20:49 UTC 2020
    - 6.1K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt

      /** 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt

      private val client = HttpClient()
    
      @BeforeEach fun setUp() {
        client.start()
      }
    
      @AfterEach fun tearDown() {
        client.stop()
      }
    
      @Test fun get(server: MockWebServer) {
        server.enqueue(MockResponse(body = "hello, Jetty HTTP Client"))
    
        val request =
          client.newRequest(server.url("/").toUri())
            .header("Accept", "text/plain")
        val response = request.send()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/CacheLoaderTest.java

    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.ImmutableMap;
    import com.google.common.collect.Queues;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.Deque;
    import java.util.Map;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java

    import java.lang.reflect.Method;
    import java.util.ArrayDeque;
    import java.util.Collection;
    import java.util.LinkedList;
    import java.util.PriorityQueue;
    import java.util.Queue;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.LinkedBlockingDeque;
    import java.util.concurrent.LinkedBlockingQueue;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. android/guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java

      @Param({"100", "10000"})
      private int size;
    
      @Param private HeapType heap;
    
      private Queue<Integer> queue;
    
      private final Random random = new Random();
    
      @BeforeExperiment
      void setUp() {
        queue = heap.create(comparator.get());
        for (int i = 0; i < size; i++) {
          queue.add(random.nextInt());
        }
      }
    
      @Benchmark
      void pollAndAdd(int reps) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 4.3K bytes
    - Viewed (0)
Back to top