- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 444 for Queues (0.04 seconds)
-
android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import java.util.List; import java.util.ListIterator; import java.util.Locale; import java.util.Map; import java.util.NavigableMap; import java.util.NavigableSet; import java.util.PriorityQueue; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.TreeMap; import java.util.TreeSet; import java.util.UUID;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 22.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/BenchmarkHelpers.java
import java.util.Collection; import java.util.HashMap; import java.util.HashSet; import java.util.LinkedHashMap; import java.util.LinkedHashSet; import java.util.Map; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Aug 10 19:54:19 GMT 2025 - 12.5K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
import com.google.common.util.concurrent.AbstractFutureBenchmarks.OldAbstractFuture; import com.google.errorprone.annotations.concurrent.GuardedBy; import java.util.LinkedList; import java.util.Queue; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.ThreadPoolExecutor;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 15.8K bytes - Click Count (0) -
cmd/bucket-replication.go
EventName: eventName, BucketName: bucket, Object: objInfo, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, }) // re-queue failures once more - keep a retry count to avoid flooding the queue if // the target site is down. Leave it to scanner to catch up instead. if rinfos.ReplicationStatus() != replication.Completed { ri.OpType = replication.HealReplicationType
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K 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) -
src/main/resources/fess_config.properties
# Number of primary shards for crawler queue index. index.document.crawler.queue.number_of_shards=10 # Number of primary shards for crawler data index. index.document.crawler.data.number_of_shards=10 # Number of primary shards for crawler filter index. index.document.crawler.filter.number_of_shards=10 # Number of replicas for crawler queue index. index.document.crawler.queue.number_of_replicas=1
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 59.3K bytes - Click Count (0) -
internal/s3select/select.go
getProgressFunc := s3Select.getProgress if !s3Select.Progress.Enabled { getProgressFunc = nil } writer := newMessageWriter(w, getProgressFunc) var outputQueue []sql.Record // Create queue based on the type. if s3Select.statement.IsAggregated() { outputQueue = make([]sql.Record, 0, 1) } else { outputQueue = make([]sql.Record, 0, 100) } var err error sendRecord := func() bool {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (0) -
docs/es/docs/alternatives.md
* [ReDoc](https://github.com/Rebilly/ReDoc) Estas dos fueron elegidas por ser bastante populares y estables, pero haciendo una búsqueda rápida, podrías encontrar docenas de interfaces de usuario alternativas para OpenAPI (que puedes usar con **FastAPI**). /// ### Frameworks REST para Flask { #flask-rest-frameworks }
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 24.5K bytes - Click Count (0) -
src/main/resources/fess_indices/fess/fr/stopwords.txt
était étions étiez étaient fus fut fûmes fûtes furent sois soit soyons soyez soient fusse fusses fût fussions fussiez fussent ayant eu eue eues eus ai as avons avez ont aurai auras aura aurons aurez auront aurais aurait aurions auriez auraient avais avait avions aviez avaient
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Nov 27 12:59:36 GMT 2023 - 977 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)