java.util.concurrent.LinkedBlockingQueue#remove ( )源码实例Demo

下面列出了java.util.concurrent.LinkedBlockingQueue#remove ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: openjdk-jdk9   文件: LinkedBlockingQueueTest.java
/**
 * retainAll(c) retains only those elements of c and reports true if changed
 */
public void testRetainAll() {
    LinkedBlockingQueue q = populatedQueue(SIZE);
    LinkedBlockingQueue p = populatedQueue(SIZE);
    for (int i = 0; i < SIZE; ++i) {
        boolean changed = q.retainAll(p);
        if (i == 0)
            assertFalse(changed);
        else
            assertTrue(changed);

        assertTrue(q.containsAll(p));
        assertEquals(SIZE - i, q.size());
        p.remove();
    }
}
 
源代码2 项目: j2objc   文件: LinkedBlockingQueueTest.java
/**
 * retainAll(c) retains only those elements of c and reports true if changed
 */
public void testRetainAll() {
    LinkedBlockingQueue q = populatedQueue(SIZE);
    LinkedBlockingQueue p = populatedQueue(SIZE);
    for (int i = 0; i < SIZE; ++i) {
        boolean changed = q.retainAll(p);
        if (i == 0)
            assertFalse(changed);
        else
            assertTrue(changed);

        assertTrue(q.containsAll(p));
        assertEquals(SIZE - i, q.size());
        p.remove();
    }
}
 
源代码3 项目: goclipse   文件: ExecutorTaskAgent_Test.java
protected void checkExceptionHandling(final LinkedBlockingQueue<Throwable> unexpectedExceptions, 
		ExecutorTaskAgent agent, Future<?> future, Class<? extends Exception> expectedKlass, boolean isExpected) 
				throws InterruptedException {
	
	try {
		future.get();
	} catch (ExecutionException ce) {
		assertTrue(expectedKlass.isInstance(ce.getCause()));
		// ok
	}
	agent.awaitPendingTasks();
	
	if(expectedKlass == null || isExpected) {
		assertTrue(unexpectedExceptions.size() == 0);
		return;
	} else {
		assertTrue(unexpectedExceptions.size() == 1);
		Throwable removed = unexpectedExceptions.remove();
		assertTrue(expectedKlass.isInstance(removed));
	}
}
 
源代码4 项目: openjdk-jdk9   文件: LinkedBlockingQueueTest.java
/**
 * remove removes next element, or throws NSEE if empty
 */
public void testRemove() {
    LinkedBlockingQueue q = populatedQueue(SIZE);
    for (int i = 0; i < SIZE; ++i) {
        assertEquals(i, q.remove());
    }
    try {
        q.remove();
        shouldThrow();
    } catch (NoSuchElementException success) {}
}
 
源代码5 项目: openjdk-jdk9   文件: LinkedBlockingQueueTest.java
/**
 * removeAll(c) removes only those elements of c and reports true if changed
 */
public void testRemoveAll() {
    for (int i = 1; i < SIZE; ++i) {
        LinkedBlockingQueue q = populatedQueue(SIZE);
        LinkedBlockingQueue p = populatedQueue(i);
        assertTrue(q.removeAll(p));
        assertEquals(SIZE - i, q.size());
        for (int j = 0; j < i; ++j) {
            Integer x = (Integer)(p.remove());
            assertFalse(q.contains(x));
        }
    }
}
 
源代码6 项目: openjdk-jdk9   文件: LinkedBlockingQueueTest.java
/**
 * Modifications do not cause iterators to fail
 */
public void testWeaklyConsistentIteration() {
    final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
    q.add(one);
    q.add(two);
    q.add(three);
    for (Iterator it = q.iterator(); it.hasNext();) {
        q.remove();
        it.next();
    }
    assertEquals(0, q.size());
}
 
源代码7 项目: java-slack-sdk   文件: AsyncRateLimitQueue.java
public synchronized void remove(String methodName, String messageId) {
    LinkedBlockingQueue<Message> activeQueue = getOrCreateActiveQueue(methodName);
    Message toRemove = null;
    for (Message message : activeQueue) {
        if (message.getId().equals(messageId)) {
            toRemove = message;
            break;
        }
    }
    activeQueue.remove(toRemove);
}
 
源代码8 项目: j2objc   文件: LinkedBlockingQueueTest.java
/**
 * remove removes next element, or throws NSEE if empty
 */
public void testRemove() {
    LinkedBlockingQueue q = populatedQueue(SIZE);
    for (int i = 0; i < SIZE; ++i) {
        assertEquals(i, q.remove());
    }
    try {
        q.remove();
        shouldThrow();
    } catch (NoSuchElementException success) {}
}
 
源代码9 项目: j2objc   文件: LinkedBlockingQueueTest.java
/**
 * removeAll(c) removes only those elements of c and reports true if changed
 */
public void testRemoveAll() {
    for (int i = 1; i < SIZE; ++i) {
        LinkedBlockingQueue q = populatedQueue(SIZE);
        LinkedBlockingQueue p = populatedQueue(i);
        assertTrue(q.removeAll(p));
        assertEquals(SIZE - i, q.size());
        for (int j = 0; j < i; ++j) {
            Integer x = (Integer)(p.remove());
            assertFalse(q.contains(x));
        }
    }
}
 
源代码10 项目: j2objc   文件: LinkedBlockingQueueTest.java
/**
 * Modifications do not cause iterators to fail
 */
public void testWeaklyConsistentIteration() {
    final LinkedBlockingQueue q = new LinkedBlockingQueue(3);
    q.add(one);
    q.add(two);
    q.add(three);
    for (Iterator it = q.iterator(); it.hasNext();) {
        q.remove();
        it.next();
    }
    assertEquals(0, q.size());
}