Examples of java.util.concurrent.BlockingQueue.take()

Class java.util.concurrent.BlockingQueue

Examples of java.util.concurrent.BlockingQueue.take()

java.util.concurrent.BlockingQueue.take()
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available. @return the head of this queue @throws InterruptedException if interrupted while waiting

                    assertEquals(i, q.take());
                }


                Thread.currentThread().interrupt();
                try {
                    q.take();
                    shouldThrow();
                } catch (InterruptedException success) {
                }
                assertFalse(Thread.interrupted());

View Full Code Here

                }
                assertFalse(Thread.interrupted());


                pleaseInterrupt.countDown();
                try {
                    q.take();
                    shouldThrow();
                } catch (InterruptedException success) {
                }
                assertFalse(Thread.interrupted());
            }

View Full Code Here

    @Test
    public void testIterator() throws InterruptedException {
        BlockingQueue q = populatedQueue(SIZE);
        Iterator it = q.iterator();
        while (it.hasNext()) {
            assertEquals(it.next(), q.take());
        }
    }


    /**
     * iterator.remove removes current element

View Full Code Here

            }
        });


        await(pleaseTake);
        assertEquals(0, q.remainingCapacity());
        assertEquals(0, q.take());


        await(pleaseInterrupt);
        assertThreadStaysAlive(t);
        t.interrupt();
        awaitTermination(t);

View Full Code Here

     */
    @Test
    public void testTake() throws Exception, IOException {
        BlockingQueue q = populatedQueue(SIZE);
        for (int i = 0; i < SIZE; ++i) {
            assertEquals(i, q.take());
        }
    }


    /**
     * Take removes existing elements until empty, then blocks interruptibly

View Full Code Here

        final BlockingQueue q = populatedQueue(SIZE);
        final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() throws Exception {
                for (int i = 0; i < SIZE; ++i) {
                    assertEquals(i, q.take());
                }


                Thread.currentThread().interrupt();
                try {
                    q.take();

View Full Code Here

                    assertEquals(i, q.take());
                }


                Thread.currentThread().interrupt();
                try {
                    q.take();
                    shouldThrow();
                } catch (InterruptedException success) {
                }
                assertFalse(Thread.interrupted());

View Full Code Here

                }
                assertFalse(Thread.interrupted());


                pleaseInterrupt.countDown();
                try {
                    q.take();
                    shouldThrow();
                } catch (InterruptedException success) {
                }
                assertFalse(Thread.interrupted());
            }

View Full Code Here

      BlockingQueue queue = address2key.get(address);
      try {
         maxNumberInvariant.readLock().lock();
         Object result;
         try {
            result = queue.take();
         } finally {
            maxNumberInvariant.readLock().unlock();
         }
         exitingNumberOfKeys.decrementAndGet();
         return result;

View Full Code Here


      try {
         maxNumberInvariant.readLock().lock();
         Object result;
         try {
            result = queue.take();
         } finally {
            maxNumberInvariant.readLock().unlock();
         }
         exitingNumberOfKeys.decrementAndGet();
         return result;

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.