- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 420 for queues (0.04 seconds)
-
src/main/resources/fess_indices/fess/es/stopwords.txt
durante todos uno les ni contra otros ese eso ante ellos e esto mí antes algunos qué unos yo otro otras otra él tanto esa estos mucho quienes nada muchos cual poco ella estar estas algunas algo nosotros mi mis tú te ti tu tus ellas nosotras vosotros vosotras os mío mía míos mías
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Mon Nov 27 12:59:36 GMT 2023 - 2.2K bytes - Click Count (0) -
mockwebserver/README.md
assertEquals("application/json; charset=utf-8", request.headers["Content-Type"]) assertEquals("{}", request.body!!.utf8()) ``` #### Dispatcher By default MockWebServer uses a queue to specify a series of responses. Use a Dispatcher (`import okhttp3.mockwebserver.Dispatcher`) to handle requests using another policy. One natural policy is to dispatch on the request path.Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 21:39:59 GMT 2025 - 8.1K bytes - Click Count (0) -
docs/pt/docs/tutorial/header-param-models.md
<img src="/img/tutorial/header-param-models/image01.png"> </div> ## Proibindo Cabeçalhos adicionais { #forbid-extra-headers } Em alguns casos de uso especiais (provavelmente não muito comuns), você pode querer **restringir** os cabeçalhos que você quer receber. Você pode usar a configuração dos modelos do Pydantic para proibir (`forbid`) quaisquer campos `extra`: {* ../../docs_src/header_param_models/tutorial002_an_py310.py hl[10] *}
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Nov 12 16:23:57 GMT 2025 - 2.9K bytes - Click Count (0) -
internal/event/target/redis.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err) } } pool := &redis.Pool{ MaxIdle: 3, IdleTimeout: 2 * 60 * time.Second, Dial: func() (redis.Conn, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0) -
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 Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 21.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// contract. // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could // drop the contract on the method that enforces this queue like behavior since depending on it // is likely to be a bug anyway. // N.B. All writes to the list and the next pointers must have happened before the aboveCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6.9K bytes - Click Count (0) -
internal/event/target/nsq.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err) } } target := &NSQTarget{ id: event.TargetID{ID: id, Name: "nsq"}, args: args, loggerOnce: loggerOnce, store: queueStore,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
docs/es/docs/advanced/sub-applications.md
# Sub Aplicaciones - Mounts { #sub-applications-mounts } Si necesitas tener dos aplicaciones de **FastAPI** independientes, cada una con su propio OpenAPI independiente y su propia interfaz de docs, puedes tener una aplicación principal y "montar" una (o más) sub-aplicación(es). ## Montar una aplicación **FastAPI** { #mounting-a-fastapi-application }Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 3.2K bytes - Click Count (0) -
internal/grid/grid.go
// This is the assumed size of bigger buffers and allocation size. biggerBufMin = 32 << 10 // This is the maximum size of bigger buffers. biggerBufMax = maxBufferSize // If there is a queue, merge up to this many messages. maxMergeMessages = 50 // clientPingInterval will ping the remote handler every 15 seconds. // Clients disconnect when we exceed 2 intervals. clientPingInterval = 15 * time.Second
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7K bytes - Click Count (0) -
cmd/metrics-v3-api.go
apiRejectedInvalidTotalMD = NewCounterMD(apiRejectedInvalidTotal, "Total number of invalid requests", "type") apiRequestsWaitingTotalMD = NewGaugeMD(apiRequestsWaitingTotal, "Total number of requests in the waiting queue", "type") apiRequestsIncomingTotalMD = NewGaugeMD(apiRequestsIncomingTotal, "Total number of incoming requests", "type") apiRequestsInFlightTotalMD = NewGaugeMD(apiRequestsInFlightTotal,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 9.4K bytes - Click Count (0)