- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 444 for queues (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)