Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 444 for queues (0.04 seconds)

  1. docs/es/docs/deployment/cloud.md

    # Despliega FastAPI en Proveedores de Nube { #deploy-fastapi-on-cloud-providers }
    
    Puedes usar prácticamente **cualquier proveedor de nube** para desplegar tu aplicación FastAPI.
    
    En la mayoría de los casos, los principales proveedores de nube tienen guías para desplegar FastAPI con ellos.
    
    ## FastAPI Cloud { #fastapi-cloud }
    
    **[FastAPI Cloud](https://fastapicloud.com)** está construido por el mismo autor y equipo detrás de **FastAPI**.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 1.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/io/ByteStreams.java

    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    import java.nio.channels.ReadableByteChannel;
    import java.nio.channels.WritableByteChannel;
    import java.util.ArrayDeque;
    import java.util.Arrays;
    import java.util.Queue;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Provides utility methods for working with byte arrays and I/O streams.
     *
     * @author Chris Nokleberg
     * @author Colin Decker
     * @since 1.0
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/thumbnail/ThumbnailManagerTest.java

            docMap.put("_id", "docid1");
    
            boolean result = thumbnailManager.offer(docMap);
            assertFalse(result);
        }
    
        // Test offer with full queue
        @Test
        public void test_offer_fullQueue() {
            thumbnailManager.setThumbnailTaskQueueSize(1);
            thumbnailManager.init();
    
            TestThumbnailGenerator generator = new TestThumbnailGenerator();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 20.4K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

        }
    
        throw firstException!!
      }
    
      /**
       * Returns non-null if we don't need to wait for the launched result. In such cases, this result
       * must be processed before whatever is waiting in the queue because we may have already acquired
       * its connection.
       */
      private fun launchTcpConnect(): ConnectResult? {
        val plan =
          when {
            routePlanner.hasNext() -> {
              try {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  5. src/main/resources/fess_indices/fess/pt/stopwords.txt

    esses
    pelas
    este
    dele
    tu
    te
    vocês
    vos
    lhes
    meus
    minhas
    teu
    tua
    teus
    tuas
    nosso
    nossa
    nossos
    nossas
    dela
    delas
    esta
    estes
    estas
    aquele
    aquela
    aqueles
    aquelas
    isto
    aquilo
    estou
    está
    estamos
    estão
    estive
    esteve
    estivemos
    estiveram
    estava
    estávamos
    estavam
    estivera
    estivéramos
    esteja
    estejamos
    estejam
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Nov 27 12:59:36 GMT 2023
    - 1.4K bytes
    - Click Count (0)
  6. cmd/metacache-server-pool.go

    			skip = act.Delete() && !act.DeleteRestored()
    		}
    	}
    
    	fiv, err := obj.fileInfoVersions(o.Bucket)
    	if err != nil {
    		return skip
    	}
    
    	// Expire all versions if needed, if not attempt to queue for replication.
    	for _, version := range fiv.Versions {
    		objInfo := version.ToObjectInfo(o.Bucket, obj.name, versioned)
    
    		if o.Lifecycle != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  7. docs/es/docs/tutorial/encoder.md

    De la misma manera, esta base de datos no recibiría un modelo de Pydantic (un objeto con atributos), solo un `dict`.
    
    Puedes usar `jsonable_encoder` para eso.
    
    Recibe un objeto, como un modelo de Pydantic, y devuelve una versión compatible con JSON:
    
    {* ../../docs_src/encoder/tutorial001_py310.py hl[4,21] *}
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 1.7K bytes
    - Click Count (0)
  8. docker-buildx.sh

    	# go build -trimpath to build the binary.
    	export GOOS=$os
    	export GOARCH=$arch
    	export MINIO_RELEASE=RELEASE
    	LDFLAGS=$(go run buildscripts/gen-ldflags.go)
    	go build -tags kqueue -trimpath --ldflags "${LDFLAGS}" -o ./minio-${arch}.${release}
    	minisign -qQSm ./minio-${arch}.${release} -s "$CRED_DIR/minisign.key" <"$CRED_DIR/minisign-passphrase"
    
    	sha256sum_str=$(sha256sum <./minio-${arch}.${release})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Oct 19 08:22:05 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  9. 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)
  10. cmd/listen-notification-handlers.go

    	}
    
    	enc := json.NewEncoder(w)
    	for {
    		select {
    		case ev := <-mergeCh:
    			_, err := w.Write(ev)
    			if err != nil {
    				return
    			}
    			if len(mergeCh) == 0 {
    				// Flush if nothing is queued
    				xhttp.Flush(w)
    			}
    			grid.PutByteBuffer(ev)
    		case <-emptyEventTicker:
    			if err := enc.Encode(struct{ Records []event.Event }{}); err != nil {
    				return
    			}
    			xhttp.Flush(w)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top