queue.offer("item" + i);
}
ArrayList<String> list = new ArrayList<String>();
queue.drainTo(list);
queue.addAll(list);
queue.removeAll(list);
final LocalQueueStats stats = queue.getLocalQueueStats();
AssertTask task = new AssertTask() {
@Override
public void run() throws Exception {