Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 228 for dequeue (0.04 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

    import assertk.assertions.isInstanceOf
    import assertk.assertions.matchesPredicate
    import java.io.IOException
    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.Proxy
    import java.util.Deque
    import java.util.concurrent.ConcurrentLinkedDeque
    import java.util.concurrent.TimeUnit
    import okhttp3.CallEvent.CacheConditionalHit
    import okhttp3.CallEvent.CacheHit
    import okhttp3.CallEvent.CacheMiss
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/TreeTraverser.java

          implements PeekingIterator<T> {
        private final Queue<T> queue;
    
        BreadthFirstIterator(T root) {
          this.queue = new ArrayDeque<>();
          queue.add(root);
        }
    
        @Override
        public boolean hasNext() {
          return !queue.isEmpty();
        }
    
        @Override
        public T peek() {
          return queue.element();
        }
    
        @Override
        public T next() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  3. docs/features/calls.md

    Calls are executed in one of two ways:
    
     * **Synchronous:** your thread blocks until the response is readable.
     * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

      private fun ensureAllTaskQueuesIdle() {
        val entryTime = System.nanoTime()
    
        for (queue in TaskRunner.INSTANCE.activeQueues()) {
          // We wait at most 1 second, so we don't ever turn multiple lost threads into
          // a test timeout failure.
          val waitTime = (entryTime + 1_000_000_000L - System.nanoTime())
          if (!queue.idleLatch().await(waitTime, TimeUnit.NANOSECONDS)) {
            TaskRunner.INSTANCE.withLock {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  5. docs/fr/docs/python-types.md

    * **Définir les prérequis** : depuis les paramètres de chemins des requêtes, les entêtes, les corps, les dépendances, etc.
    * **Convertir des données** : depuis la requête vers les types requis.
    * **Valider des données** : venant de chaque requête :
        * Générant automatiquement des **erreurs** renvoyées au client quand la donnée est invalide.
    * **Documenter** l'API avec OpenAPI :
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/CallHandshakeTest.kt

      val expectedModernTls13CipherSuites = listOf(TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256, TLS_AES_128_GCM_SHA256, TLS_AES_256_GCM_SHA384)
    
      @BeforeEach
      fun setup() {
        server.enqueue(MockResponse())
    
        client =
          clientTestRule
            .newClientBuilder()
            .sslSocketFactory(
              handshakeCertificates.sslSocketFactory(),
              handshakeCertificates.trustManager,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  7. src/main/resources/crawler_es+crawlerConfig.xml

    	"http://dbflute.org/meta/lastadi10.dtd">
    <components namespace="fessCrawler">
    	<component name="crawlerConfig" class="org.codelibs.fess.crawler.util.FessCrawlerConfig">
    		<property name="queueIndex">"fess_crawler.queue"</property>
    		<property name="queueShards">5</property>
    		<property name="queueReplicas">1</property>
    		<property name="dataIndex">"fess_crawler.data"</property>
    		<property name="dataShards">5</property>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Fri Dec 03 13:06:40 UTC 2021
    - 756 bytes
    - Viewed (0)
  8. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt

        responses: MutableList<InetAddress>,
        failures: MutableList<Exception>,
      ) {
        val latch = CountDownLatch(networkRequests.size)
    
        for (call in networkRequests) {
          call.enqueue(
            object : Callback {
              override fun onFailure(
                call: Call,
                e: IOException,
              ) {
                synchronized(failures) {
                  failures.add(e)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat May 10 11:15:14 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  9. docs/fr/docs/project-generation.md

    ## Modèles d'apprentissage automatique avec spaCy et FastAPI - Fonctionnalités
    
    * Intégration d'un modèle NER **spaCy**.
    * Formatage de requête pour **Azure Cognitive Search**.
    * Serveur Python web **prêt à utiliser en production** utilisant Uvicorn et Gunicorn.
    * Déploiement CI/CD Kubernetes pour **Azure DevOps** (AKS).
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Jul 29 23:35:07 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        task.nextExecuteNanoTime = -1L
        val queue = task.queue!!
        queue.futureTasks.remove(task)
        readyQueues.remove(queue)
        queue.activeTask = task
        busyQueues.add(queue)
      }
    
      private fun afterRun(
        task: Task,
        delayNanos: Long,
        completedNormally: Boolean,
      ) {
        assertLockHeld()
    
        val queue = task.queue!!
        check(queue.activeTask === task)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top