Thread.sleep(3000);
}
synchronized (fifo) {
//设立一个等待时间
boolean resultOfWait = fifo.waitUntilEmpty(500);
print("did waitUntilEmpty(500), resultOfWait=" +
resultOfWait + ", getSize()=" +
fifo.getSize());
}
//调用三次removeAll方法
for (int i = 0; i < 3; i++) {
synchronized (fifo) {
Object[] list = fifo.removeAll();
print("did removeAll(), list.length=" +
list.length);
for (int j = 0; j < list.length; j++) {
print("DATA-OUT - list[" + j + "]=" +
list[j]);
}
}
Thread.sleep(100);
}
for (int i = 0; i < 3; i++) {
synchronized (fifo) {
Object[] list = fifo.removeAtLeastOne();
print(
"did removeAtLeastOne(), list.length=" +
list.length);
for (int j = 0; j < list.length; j++) {
print("DATA-OUT - list[" + j + "]=" +
list[j]);