Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 328 for queued (0.06 seconds)

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

  1. okhttp/src/jvmTest/kotlin/okhttp3/RecordingCallback.kt

        responses.add(RecordedResponse(call.request(), response, null, body, null))
        (this as Object).notifyAll()
      }
    
      /**
       * Returns the recorded response triggered by `request`. Throws if the response isn't
       * enqueued before the timeout.
       */
      @Synchronized
      fun await(url: HttpUrl): RecordedResponse {
        val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS
        while (true) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  2. internal/http/dial_linux.go

    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_NODELAY, 1)
    				_ = syscall.SetsockoptInt(fd, syscall.SOL_TCP, unix.TCP_CORK, 0)
    			}
    
    			// Enable TCP open
    			// https://lwn.net/Articles/508865/ - 32k queue size.
    			_ = syscall.SetsockoptInt(fd, syscall.SOL_TCP, unix.TCP_FASTOPEN, 32*1024)
    
    			// Enable TCP fast connect
    			// TCPFastOpenConnect sets the underlying socket to use
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 23 10:53:03 GMT 2024
    - 5K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

    import okhttp3.internal.connection.RealCall
    import okhttp3.internal.finishedAccessor
    
    /**
     * A fake executor for testing that never executes anything! Instead, it just keeps track of what's
     * been enqueued.
     */
    internal class RecordingExecutor(
      private val dispatcherTest: DispatcherTest,
    ) : AbstractExecutorService() {
      private var shutdown: Boolean = false
      private val calls = mutableListOf<RealCall.AsyncCall>()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Oct 06 18:34:01 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

    import java.util.LinkedList;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Tests for {@link Synchronized#deque} and {@link Queues#synchronizedDeque}.
     *
     * @author Kurt Alfred Kluever
     */
    @NullUnmarked
    public class SynchronizedDequeTest extends TestCase {
    
      protected Deque<String> create() {
        TestDeque<String> inner = new TestDeque<>();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  5. docs/es/docs/tutorial/request-form-models.md

    <img src="/img/tutorial/request-form-models/image01.png">
    </div>
    
    ## Prohibir Campos de Formulario Extra { #forbid-extra-form-fields }
    
    En algunos casos de uso especiales (probablemente no muy comunes), podrías querer **restringir** los campos de formulario a solo aquellos declarados en el modelo de Pydantic. Y **prohibir** cualquier campo **extra**.
    
    /// note | Nota
    
    Esto es compatible desde la versión `0.114.0` de FastAPI. 🤓
    
    ///
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 2.3K bytes
    - Click Count (0)
  6. docs/en/docs/tutorial/background-tasks.md

    They tend to require more complex configurations, a message/job queue manager, like RabbitMQ or Redis, but they allow you to run background tasks in multiple processes, and especially, in multiple servers.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  7. docs/fr/docs/tutorial/background-tasks.md

    Ces outils nécessitent généralement des configurations plus complexes ainsi qu'un gestionnaire de queue de message, comme RabbitMQ ou Redis, mais ils permettent d'exécuter des tâches d'arrière-plan dans différents process, et surtout, sur plusieurs serveurs.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 5.5K bytes
    - Click Count (0)
  8. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 21.4K bytes
    - Click Count (0)
  9. docs/de/docs/tutorial/background-tasks.md

    Sie erfordern in der Regel komplexere Konfigurationen und einen Nachrichten-/Job-Queue-Manager wie RabbitMQ oder Redis, ermöglichen Ihnen jedoch die Ausführung von Hintergrundtasks in mehreren Prozessen und insbesondere auf mehreren Servern.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:58:09 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java

            }
        }
    
        /**
         * Stores a failure URL with error information for later analysis.
         *
         * @param crawlerContext the crawler context
         * @param urlQueue the URL queue containing the failed URL
         * @param errorName the name/type of the error
         * @param e the throwable that caused the failure
         * @return the stored FailureUrl entity
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 8.3K bytes
    - Click Count (0)
Back to Top