与生产者/消费者线程重叠50%的滑动窗口

Question

我在 Java 中有以下场景：

• 1生产者线程将事件对象存储到队列中。阻塞它不是一个选项。它应该始终将每个元素存储在队列的末尾并退出（因此没有有界队列）。
• 1个消费者线程等待队列中有WINDOW_SIZE数量的事件。然后它应该从队列中检索所有WINDOW_SIZE事件进行处理，但只删除其中的一半（即WINDOW_SIZE/2），重叠率为50%。

我的问题是，您将使用哪个(并发)集合来高效地实现这一点？事件在资源有限的设备(运行Android的手机)上以100Hz的频率出现。我想到了使用下面这些，但没有一个是合适的:

1. ConcurrentLinkedQueue，每次修改队列时检查队列大小，并在WINDOW_SIZE事件可用时在使用者中使用 peek（）/poll（）。这似乎有点麻烦。
2. 一个 ArrayBlockingQueue，再次检查队列大小，并使用 drainTo（）。但是，该方法具有以下文档：“[...]此外，如果在操作正在进行时修改指定的集合，则未定义此操作的行为。[...]".对于并发集合来说，这似乎有点奇怪。

这是一些示例代码：

import java.util.Queue;

import com.google.common.collect.Queues;

public class AccelerometerProcessor implements Runnable {

    private static final int WINDOW_SIZE = 128;

    private final Queue<AccelerometerEvent> eventQueue = Queues.newConcurrentLinkedQueue();

    @Override
    public void run() {
        while (!Thread.interrupted()) {
            try {
                synchronized (eventQueue) {
                    while (eventQueue.size() < WINDOW_SIZE) {
                        eventQueue.wait();
                    }

                    // We have WINDOW_SIZE eventQueue, start processing
                }
            } catch (InterruptedException e) {
                // Do nothing
            }
        }
    }

    public void addAccelerometerEvent(AccelerometerEvent accelerometerEvent) {
        synchronized (eventQueue) {
            eventQueue.add(accelerometerEvent);
            eventQueue.notifyAll();
        }
    }
}

顺便说一下，我也在用谷歌番石榴，所以如果那里有我没听说过的不错的收藏，请推荐给我。

那么：有什么好主意可以有效、干净地解决这个问题吗？

Answer 1

如果您总是要整体使用 WINDOW_SIZE/2 个事件，为什么生产者线程（您说只有一个）不填充大小为 WINDOW_SIZE/2 的数组并在它填满后将其传递给队列？