Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 374 for queued (0.22 sec)

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

     * defined as the <i>least</i> element in the queue according to the queue's comparator. But unlike
     * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link
     * #removeLast} are also provided, to act on the <i>greatest</i> element in the queue instead.
     *
     * <p>A min-max priority queue can be configured with a maximum size. If so, each time the size of
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

       * Attempts to remove a single frame from a queue and send it. This prefers to write urgent pongs
       * before less urgent messages and close frames. For example it's possible that a caller will
       * enqueue messages followed by pongs, but this sends pongs followed by messages. Pongs are always
       * written in the order they were enqueued.
       *
       * If a frame cannot be sent - because there are none enqueued or because the web socket is not
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/collect/testing/TestQueueGenerator.java

    import java.util.Queue;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Creates queues, containing sample elements, to be tested.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public interface TestQueueGenerator<E extends @Nullable Object> extends TestCollectionGenerator<E> {
      @Override
      Queue<E> create(Object... elements);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 21 16:49:06 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

    import java.util.Collection;
    import java.util.Iterator;
    import java.util.Queue;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Tests for {@link Synchronized#queue} and {@link Queues#synchronizedQueue}.
     *
     * @author Kurt Alfred Kluever
     */
    public class SynchronizedQueueTest extends TestCase {
    
      protected Queue<String> create() {
        TestQueue<String> inner = new TestQueue<>();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

    import java.util.Collection;
    import java.util.Iterator;
    import java.util.Queue;
    import junit.framework.TestCase;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Tests for {@link Synchronized#queue} and {@link Queues#synchronizedQueue}.
     *
     * @author Kurt Alfred Kluever
     */
    public class SynchronizedQueueTest extends TestCase {
    
      protected Queue<String> create() {
        TestQueue<String> inner = new TestQueue<>();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 19 20:50:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

          "FINE: Q10000 finished run in   0 µs: task one",
        )
      }
    
      /**
       * The runner doesn't hold references to its queues! Otherwise we'd need a mechanism to clean them
       * up when they're no longer needed and that's annoying. Instead the task runner only tracks which
       * queues have work scheduled.
       */
      @Test fun activeQueuesContainsOnlyQueuesWithScheduledTasks() {
        redQueue.execute("task one", 100.µs) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 23K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.Lists;
    import com.google.common.collect.Queues;
    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.Lists;
    import com.google.common.collect.Queues;
    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. internal/event/config.go

    	Events []Name `xml:"Event" json:"Event"`
    }
    
    // Queue - represents elements inside <QueueConfiguration>
    type Queue struct {
    	common
    	ARN ARN `xml:"Queue"`
    }
    
    // UnmarshalXML - decodes XML data.
    func (q *Queue) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type queue Queue
    	parsedQueue := queue{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

                waitingCoordinatorInterrupted = false
                throw InterruptedException()
              }
            }
    
            override fun <T> decorate(queue: BlockingQueue<T>) = TaskFakerBlockingQueue(queue)
          },
          logger = logger,
        )
    
      /** Runs all tasks that are ready. Used by the test thread only. */
      fun runTasks() {
        advanceUntil(nanoTime)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
Back to top