- Sort Score
- Num 10 results
- Language All
Results 211 - 220 of 444 for Queues (0.04 seconds)
-
internal/s3select/json/preader.go
r.bufferPool.New = func() []byte { return make([]byte, jsonSplitSize+1024) } // Create queue r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.input = make(chan *queueItem, runtime.GOMAXPROCS(0)) r.readerWg.Add(1) // Start splitter go func() { defer close(r.input) defer close(r.queue) defer r.readerWg.Done() for { next, err := r.nextSplit(jsonSplitSize, r.bufferPool.Get())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
docs/es/docs/tutorial/index.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 5.6K bytes - Click Count (0) -
android/guava/src/com/google/common/base/FinalizableWeakReference.java
/** * Constructs a new finalizable weak reference. * * @param referent to weakly reference * @param queue that should finalize the referent */ protected FinalizableWeakReference(@Nullable T referent, FinalizableReferenceQueue queue) { super(referent, queue.queue); queue.cleanUp(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0) -
guava/src/com/google/common/base/FinalizableWeakReference.java
/** * Constructs a new finalizable weak reference. * * @param referent to weakly reference * @param queue that should finalize the referent */ protected FinalizableWeakReference(@Nullable T referent, FinalizableReferenceQueue queue) { super(referent, queue.queue); queue.cleanUp(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} private void enqueueHelper(Event<L> event, Object label) { checkNotNull(event, "event"); checkNotNull(label, "label"); synchronized (listeners) { for (PerListenerQueue<L> queue : listeners) { queue.add(event, label); } } } /** * Dispatches all events enqueued prior to this call, serially and in order, for every listener. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 8.1K bytes - Click Count (0) -
cmd/site-replication-metrics_gen.go
} case "ReplicaCount": z.ReplicaCount, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "ReplicaCount") return } case "Queued": err = z.Queued.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Queued") return } case "Proxied": err = z.Proxied.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Proxied") return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 40.3K bytes - Click Count (0) -
docs/es/docs/environment-variables.md
Las variables de entorno pueden ser útiles para manejar **configuraciones** de aplicaciones, como parte de la **instalación** de Python, etc. ## Crear y Usar Variables de Entorno { #create-and-use-env-vars } Puedes **crear** y usar variables de entorno en la **shell (terminal)**, sin necesidad de Python: //// tab | Linux, macOS, Windows Bash <div class="termy"> ```console // Podrías crear una env var MY_NAME conCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 8.3K bytes - Click Count (0) -
internal/event/errors.go
} // ErrDuplicateQueueConfiguration - duplicate queue configuration error. type ErrDuplicateQueueConfiguration struct { Queue Queue } func (err ErrDuplicateQueueConfiguration) Error() string { var message string if data, xerr := xml.Marshal(err.Queue); xerr != nil { message = fmt.Sprintf("%+v", err.Queue) } else { message = string(data) }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.1K bytes - Click Count (0) -
docs/es/docs/index.md
* ...y más. ### Despliega tu app (opcional) { #deploy-your-app-optional } Opcionalmente puedes desplegar tu app de FastAPI en [FastAPI Cloud](https://fastapicloud.com), ve y únete a la lista de espera si no lo has hecho. 🚀 Si ya tienes una cuenta de **FastAPI Cloud** (te invitamos desde la lista de espera 😉), puedes desplegar tu aplicación con un solo comando. <div class="termy"> ```console $ fastapi deploy
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 22.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java
} catch (final Exception e) { maxBufferSize = 1000; } queue.offer(event); if (size.incrementAndGet() > maxBufferSize) { if (queue.poll() != null) { size.decrementAndGet(); } } } /** * Drains all events from the buffer and returns them as a list.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 5.3K bytes - Click Count (0)