ArrayBlockingQueue 实现队列达到一定数据量返回和达到一定时间返回

`ArrayBlockingQueue` 实现了 `BlockingQueue` 接口，提供了多个阻塞方法，包括 `put()`、`take()`、`offer()` 等。如果你想在队列达到一定数据量或达到一定时间时返回，可以结合这些阻塞方法进行实现。

一种实现方式是使用 `offer()` 方法，该方法会尝试将元素插入队列中，如果队列已经满了，它会返回 false，否则返回 true。结合计数器可以实现在队列达到一定数据量时返回。示例代码如下：

ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(100);
int count = 0;
while (true) {
    String data = getData();
    if (queue.offer(data)) {
        count++;
    }
    if (count >= 100) {
        break;
    }
}

另一种实现方式是使用 `poll()` 方法，该方法会尝试从队列中取出一个元素，如果队列为空，它会返回 null。结合时间戳可以实现在队列达到一定时间时返回。示例代码如下：

ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(100);
long startTime = System.currentTimeMillis();
while (true) {
    String data = getData();
    if (queue.offer(data)) {
        if (System.currentTimeMillis() - startTime >= 5000) {
            break;
        }
    }
}

上述代码中，当队列中元素数量达到 100 个时，循环会退出；当从开始插入元素到现在的时间大于等于 5000 毫秒时，循环也会退出。你也可以使用 `put()` 和 `take()` 方法来实现类似的功能，这些方法会在队列满或空时阻塞线程，直到有空间或元素可用。