Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 351 for Queues (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/collect/Iterators.java

          return !queue.isEmpty();
        }
    
        @Override
        @ParametricNullness
        public T next() {
          IndexedIterator<T> nextIndexed = queue.remove();
          PeekingIterator<T> nextIter = nextIndexed.iterator;
          T next = nextIter.next();
          if (nextIter.hasNext()) {
            queue.add(nextIndexed);
          }
          return next;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Iterators.java

          return !queue.isEmpty();
        }
    
        @Override
        @ParametricNullness
        public T next() {
          IndexedIterator<T> nextIndexed = queue.remove();
          PeekingIterator<T> nextIter = nextIndexed.iterator;
          T next = nextIter.next();
          if (nextIter.hasNext()) {
            queue.add(nextIndexed);
          }
          return next;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/cache/TestingRemovalListeners.java

      static <K, V> CountingRemovalListener<K, V> countingRemovalListener() {
        return new CountingRemovalListener<>();
      }
    
      /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */
      @J2ktIncompatible
      @GwtIncompatible // ConcurrentLinkedQueue
      static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>>
          implements RemovalListener<K, V> {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 13:13:59 GMT 2026
    - 3.2K bytes
    - Click Count (0)
  4. internal/config/notify/help.go

    		},
    		config.HelpKV{
    			Key:         target.AmqpAutoDeleted,
    			Description: "auto delete queue when set to 'on', when there are no consumers",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpDeliveryMode,
    			Description: "set to '1' for non-persistent or '2' for persistent queue",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  5. docs/es/docs/advanced/middleware.md

    Como **FastAPI** está basado en Starlette e implementa la especificación <abbr title="Asynchronous Server Gateway Interface - Interfaz de puerta de enlace de servidor asíncrona">ASGI</abbr>, puedes usar cualquier middleware ASGI.
    
    Un middleware no tiene que estar hecho para FastAPI o Starlette para funcionar, siempre que siga la especificación ASGI.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  6. guava-testlib/src/com/google/common/collect/testing/testers/QueuePeekTester.java

    import com.google.common.collect.testing.features.CollectionFeature;
    import com.google.common.collect.testing.features.CollectionSize;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code peek()} operations on a queue. Can't be invoked directly;
     * please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  7. guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    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.8K bytes
    - Click Count (0)
  8. src/main/resources/fess_label_de.properties

    labels.suggestWord=Wort vorschlagen
    labels.targetLabel=Label
    labels.term=Begriff
    labels.fields=Felder
    labels.ex_q=Erweiterte Abfrage
    labels.oldPassword=Aktuelles Passwort
    labels.newPassword=Neues Passwort
    labels.confirmNewPassword=Neues Passwort (bestätigen)
    
    labels.menu_system=System
    labels.menu_wizard=Assistent
    labels.menu_crawl_config=Allgemein
    labels.menu_scheduler_config=Scheduler
    labels.menu_dashboard_config=Dashboard
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:54:13 GMT 2026
    - 52.3K bytes
    - Click Count (1)
  9. docs/es/docs/tutorial/security/index.md

    Eso es lo que hace posible tener múltiples interfaces de documentación interactiva automática, generación de código, etc.
    
    OpenAPI tiene una forma de definir múltiples "esquemas" de seguridad.
    
    Al usarlos, puedes aprovechar todas estas herramientas basadas en estándares, incluidos estos sistemas de documentación interactiva.
    
    OpenAPI define los siguientes esquemas de seguridad:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 10:15:01 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  10. 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)
Back to Top