重复非锁定条件信号的 Java 抽象

Question

抱歉，标题令人困惑。不太确定如何表达它，这可能是问题所在!

我正在寻找一个好的抽象来用于涉及并发线程的情况。

我已经接近了，但还不是很清楚。

稍微简化一下，我在 Android 手机上收集了两种传感器输入 - 方向类型的东西和 WiFi 扫描。

当两者都已收集到足够多时，我想触发一个使用数据的事件。然而，我不想就此打住——这个过程应该继续 N 次。

起初我只是在条件上使用 while 循环，例如

startCollecting();
while (samplesCollected < X){
    // wait
    while (directionCount < Y || scanCount < Z){}; 
    // then
    doSomeStuff();
    samplesCollected++; 
}
stopCollecting();

但是，SO 告诉我这是一个糟糕的表现，而且我确实遇到了 UI 的一些锁定(即使它在不同的线程上)，所以我决定使用 java.util。并发。

问题是我不太清楚应该使用哪种抽象，可能是因为我没有经验。

• ReentrantLock 的条件:

  条件的想法似乎很棒 - 但我不想控制共享资源 - 我希望数据收集在处理第一批时在后台继续 - 那么我在哪里调用锁定？如果我不锁定，它就会抛出 IllegalMonitorStateException。

• 倒计时锁:

  看起来很理想——当收集线程有可用数据时，它们可以调用 countDown()，当 countDown 被调用足够多次时，操作可以继续。但是 countDown 应该是一次性执行，我需要重复几次。

• 循环屏障:

  CountdownLatch 的文档建议如果您希望行为可重复，则应改用 CyclicBarrier - 但 CyclicBarrier 的隐喻对于这种情况似乎完全错误，我不明白如何使用它。

我在下面链接了一些相关问题 - 任何指导将不胜感激。

Efficiency - use of Thread.yield in loop that waits for variable change

How to make a Java thread wait for another thread's output?

is there a 'block until condition becomes true' function in java?

A simple scenario using wait() and notify() in java

Answer 1

我们的代码中有类似的实现。我们创建了一个内部类，它实现了 runnable 并且可以处理数据。我们继续在单个线程中读取数据，一旦数据大小达到特定限制，我们就会将该数据传递给内部类的一个实例，并将该内部类实例作为任务提交给 ThreadPoolExecutor 服务。

这对我们来说效果很好。