Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 444 for Queues (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top